Optimized codes

Author: huangdijia

composer.json

@@ -22,7 +22,7 @@
         "pull-request": "https://github.com/friendsofhyperf/components/pulls"
     },
     "require": {
-        "friendsofhyperf/icp-broadcaster": "~3.1.1",
+        "friendsofhyperf/icp-broadcaster": "~3.1.2",
         "hyperf/event": "~3.1.0"
     },
     "minimum-stability": "dev",

src/PipeMessage.php

@@ -14,7 +14,6 @@
 use FriendsOfHyperf\IpcBroadcaster\IpcMessage;
 use Hyperf\Context\ApplicationContext;
 use Hyperf\Contract\StdoutLoggerInterface;
-use Psr\Container\ContainerInterface;
 use Throwable;
 
 class PipeMessage extends IpcMessage
@@ -28,50 +27,35 @@ public function __construct(
     public function handle(): void
     {
         try {
-            if (! $sender = $this->getSender()) {
+            if (! $sender = $this->get(Sender::class)) {
                 return;
             }
 
             $params = $sender->getFdAndMethodFromProxyMethod($this->method, $this->arguments);
 
             $sender->proxy(...$params);
         } catch (Throwable $exception) {
-            $this->getLogger()?->warning((string) $exception);
+            $this->get(StdoutLoggerInterface::class)?->warning((string) $exception);
         }
     }
 
-    private function getLogger(): ?StdoutLoggerInterface
+    /**
+     * @template T
+     * @param class-string<T> $class
+     * @return T|null
+     */
+    private function get(string $class)
     {
-        if (! $container = $this->getContainer()) {
-            return null;
-        }
-
-        if (! $container->has(StdoutLoggerInterface::class)) {
-            return null;
-        }
-
-        return $container->get(StdoutLoggerInterface::class);
-    }
-
-    private function getSender(): ?Sender
-    {
-        if (! $container = $this->getContainer()) {
-            return null;
-        }
-
-        if (! $container->has(Sender::class)) {
+        if (! ApplicationContext::hasContainer()) {
             return null;
         }
 
-        return $container->get(Sender::class);
-    }
+        $container = ApplicationContext::getContainer();
 
-    private function getContainer(): ?ContainerInterface
-    {
-        if (! ApplicationContext::hasContainer()) {
+        if (! $container->has($class)) {
             return null;
         }
 
-        return ApplicationContext::getContainer();
+        return $container->get($class);
     }
 }