| Methods |
public
|
__construct(
bool $toolsListChanged = false,
bool $promptsListChanged = false,
bool $resourcesListChanged = false,
bool $resourceSubscriptions = false,
LoggerInterface $logger = new NullLogger(),
int<1, max> $maxSubscriptions = self::DEFAULT_MAX_SUBSCRIPTIONS,
int<1, max> $maxSubscriptionsPerPeer = self::DEFAULT_MAX_SUBSCRIPTIONS_PER_PEER,
int<1, max> $maxResourceSubscriptionsPerStream = self::DEFAULT_MAX_RESOURCE_SUBSCRIPTIONS_PER_STREAM,
)
|
#
|
public
|
open(
RequestId $subscriptionId,
SubscriptionFilter $requested,
SenderInterface $sender,
?string $peer = null,
): SubscriptionEntry
Opens a stream, acknowledging it before it becomes visible to any emit.
Opens a stream, acknowledging it before it becomes visible to any emit.
Parameters
| $subscriptionId |
Id carried by every message on the stream, as the client sent it
|
| $peer |
Stable peer identity for the per-peer budget, null when the transport cannot supply one
|
Implements
|
#
|
public
|
close(SubscriptionEntry $entry): void
Tears $entry down, naming the ending subscriptions/listen to the client and releasing the
handler, and does nothing for a stream already gone.
Tears $entry down, naming the ending subscriptions/listen to the client and releasing the
handler, and does nothing for a stream already gone.
Implements
|
#
|
public
|
discard(SubscriptionEntry $entry): void
Deregisters $entry without announcing anything, for a stream already abandoned by the client.
Deregisters $entry without announcing anything, for a stream already abandoned by the client.
Implements
|
#
|
public
|
closeAll(): void
Closes every open stream so the server can drain, settling any opened afterwards at once.
Closes every open stream so the server can drain, settling any opened afterwards at once.
Implements
|
#
|
public
|
reopen(): void
Clears the drained state left by closeAll(), so a store reused on a new transport serves live streams again.
Clears the drained state left by closeAll(), so a store reused on a new transport serves live streams again.
Implements
|
#
|
public
|
emitToolListChanged(): void
|
#
|
public
|
emitPromptListChanged(): void
|
#
|
public
|
emitResourceListChanged(): void
|
#
|
public
|
emitResourceUpdated(string $uri): void
Announces that the contents behind $uri changed, to the streams subscribed to that URI.
Announces that the contents behind $uri changed, to the streams subscribed to that URI.
Implements
|
#
|
public
|
honour(SubscriptionFilter $requested): SubscriptionFilter
Narrows $requested to the notification types delivered by this store, omitting rather than
falsifying the ones it does not honour.
Narrows $requested to the notification types delivered by this store, omitting rather than
falsifying the ones it does not honour.
Implements
|
#
|