Class Nexus\Mcp\Client\Subscription\SubscriptionStream

`final`

An open subscriptions/listen stream. Ends when the caller closes it or the server tears it down. A supervised transport re-opens it against each replacement peer under the same subscription id, so neither the id nor this object is spent by a restart.

Located at Client/Subscription/SubscriptionStream.php

Methods


					
	public

close(): void

Stops the stream, telling the server the subscription is over. Subsequent calls are no-ops.


					
	public

await(): SubscriptionsListenResult

Blocks until the server tears the subscription down of its own accord. A peer that dies under supervision does not settle this: the wait resumes against the replacement.

Throws

`Nexus\Mcp\Core\Exception\RemoteCallFailedException`
`Nexus\Mcp\Client\Exception\SubscriptionClosedException`

Namespaces

Classes

Class Nexus\Mcp\Client\Subscription\SubscriptionStream

Throws