diff --git a/src/Stream/Stream.php b/src/Stream/Stream.php index df9c191..a0284d1 100644 --- a/src/Stream/Stream.php +++ b/src/Stream/Stream.php @@ -7,6 +7,7 @@ use Basis\Nats\Client; use Basis\Nats\Consumer\Consumer; use Basis\Nats\Consumer\Configuration as ConsumerConfiguration; +use Basis\Nats\Message\Payload; class Stream { @@ -88,6 +89,9 @@ public function getName(): string return $this->configuration->getName(); } + /** + * @return Payload + */ public function info() { return $this->client->api("STREAM.INFO." . $this->getName());