| 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 every message on the stream carries, 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 the client already abandoned.
Deregisters $entry without announcing anything, for a stream the client already abandoned.
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 this store delivers, omitting rather than
falsifying the ones it does not honour.
Narrows $requested to the notification types this store delivers, omitting rather than
falsifying the ones it does not honour.
Implements
|
#
|