InMemoryTransport extends BaseTransport
Provides a skeletal implementation of the TransportInterface to minimize the effort required to implement this interface.
Tags
Table of Contents
Properties
- $fiberYieldHandler : callable(Array, Array): void
- $logger : LoggerInterface
- $messageListener : callable(TransportInterface<string|int, mixed>, string, Array): void
-
$outgoingMessagesProvider
: callable(Uuid): array<int, array{message: string, context: array
- $pendingRequestsProvider : callable(Uuid): array<int, array<string, mixed>>
- $responseFinder : callable(int, Uuid): Response<string|int, array<string, mixed>>|Error|null
- $sessionEndListener : callable(Uuid): void
- $sessionFiber : McpFiber|null
- $sessionId : Uuid|null
- $messages : array<string|int, mixed>
Methods
- __construct() : mixed
- attachFiberToSession() : void
- close() : void
- Closes the transport and cleans up any resources.
- initialize() : void
- Initializes the transport.
- listen() : null
- Starts the transport's execution process.
- onMessage() : void
- Register callback for ALL incoming messages.
- onSessionEnd() : void
- send() : void
- Send a message to the client immediately (bypassing session queue).
- setFiberYieldHandler() : void
- setOutgoingMessagesProvider() : void
- setPendingRequestsProvider() : void
- setResponseFinder() : void
- setSessionId() : void
- Set the session ID for the current transport context.
- checkForResponse() : Response|Error|null
-
getOutgoingMessages()
: array<int, array{message: string, context: array
- getPendingRequests() : array<int, array<string, mixed>>
- handleFiberYield() : void
- handleMessage() : void
- handleSessionEnd() : void
Properties
$fiberYieldHandler
protected
callable(Array, Array): void
$fiberYieldHandler
$logger
protected
LoggerInterface
$logger
$messageListener
protected
callable(TransportInterface<string|int, mixed>, string, Array): void
$messageListener
$outgoingMessagesProvider
protected
callable(Uuid): array<int, array{message: string, context: array}>
$outgoingMessagesProvider
$pendingRequestsProvider
protected
callable(Uuid): array<int, array<string, mixed>>
$pendingRequestsProvider
$responseFinder
protected
callable(int, Uuid): Response<string|int, array<string, mixed>>|Error|null
$responseFinder
$sessionEndListener
protected
callable(Uuid): void
$sessionEndListener
$sessionFiber
protected
McpFiber|null
$sessionFiber
= null
$sessionId
protected
Uuid|null
$sessionId
= null
$messages read-only
private
array<string|int, mixed>
$messages
= []
Methods
__construct()
public
__construct([array<int, string> $messages = [] ][, LoggerInterface|null $logger = null ]) : mixed
Parameters
- $messages : array<int, string> = []
- $logger : LoggerInterface|null = null
attachFiberToSession()
public
attachFiberToSession(McpFiber $fiber, Uuid $sessionId) : void
Parameters
- $fiber : McpFiber
- $sessionId : Uuid
close()
Closes the transport and cleans up any resources.
public
close() : void
initialize()
Initializes the transport.
public
initialize() : void
listen()
Starts the transport's execution process.
public
listen() : null
Return values
nullonMessage()
Register callback for ALL incoming messages.
public
onMessage(callable $listener) : void
The transport calls this whenever ANY message arrives, regardless of source.
Parameters
- $listener : callable
onSessionEnd()
public
onSessionEnd(callable $listener) : void
Parameters
- $listener : callable
send()
Send a message to the client immediately (bypassing session queue).
public
send(string $data, array<string|int, mixed> $context) : void
Used for session resolution errors when no session is available. The transport decides HOW to send based on context.
Parameters
- $data : string
- $context : array<string|int, mixed>
-
Context about this message:
- 'session_id': Uuid|null
- 'type': 'response'|'request'|'notification'
- 'status_code': int (HTTP status code for errors)
setFiberYieldHandler()
public
setFiberYieldHandler(callable(Array, Array): void $handler) : void
Parameters
- $handler : callable(Array, Array): void
setOutgoingMessagesProvider()
public
setOutgoingMessagesProvider(callable $provider) : void
Parameters
- $provider : callable
setPendingRequestsProvider()
public
setPendingRequestsProvider(callable $provider) : void
Parameters
- $provider : callable
setResponseFinder()
public
setResponseFinder(callable(int, Uuid): Array $finder) : void
Parameters
- $finder : callable(int, Uuid): Array
setSessionId()
Set the session ID for the current transport context.
public
setSessionId(Uuid|null $sessionId) : void
Parameters
- $sessionId : Uuid|null
-
The session ID, or null to clear
checkForResponse()
protected
checkForResponse(int $requestId, Uuid|null $sessionId) : Response|Error|null
Parameters
- $requestId : int
- $sessionId : Uuid|null
Tags
Return values
Response|Error|nullgetOutgoingMessages()
protected
getOutgoingMessages(Uuid|null $sessionId) : array<int, array{message: string, context: array}>
Parameters
- $sessionId : Uuid|null
Return values
array<int, array{message: string, context: arraygetPendingRequests()
protected
getPendingRequests(Uuid|null $sessionId) : array<int, array<string, mixed>>
Parameters
- $sessionId : Uuid|null
Return values
array<int, array<string, mixed>>handleFiberYield()
protected
handleFiberYield(FiberSuspend|null $yielded, Uuid|null $sessionId) : void
Parameters
- $yielded : FiberSuspend|null
- $sessionId : Uuid|null
handleMessage()
protected
handleMessage(string $payload, Uuid|null $sessionId) : void
Parameters
- $payload : string
- $sessionId : Uuid|null
handleSessionEnd()
protected
handleSessionEnd(Uuid|null $sessionId) : void
Parameters
- $sessionId : Uuid|null