rune-langium / lsp-server/src / DurableObjectWebSocketTransport
Class: DurableObjectWebSocketTransport
Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:68
Implements
Transport
Constructors
Constructor
new DurableObjectWebSocketTransport(socket): DurableObjectWebSocketTransport;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:75
Parameters
| Parameter | Type |
|---|---|
socket | CfWebSocketLike |
Returns
DurableObjectWebSocketTransport
Methods
close()
close(): Promise<void>;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:153
Close the transport connection and release resources.
Returns
Promise<void>
Implementation of
Transport.close
isConnected()
isConnected(): boolean;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:170
Returns true if the transport is currently connected and able to send messages.
Returns
boolean
Implementation of
Transport.isConnected
onClose()
onClose(handler): Disposable;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:148
Subscribe to connection close.
Parameters
| Parameter | Type | Description |
|---|---|---|
handler | () => void | Callback invoked when the transport is closed. |
Returns
Disposable
A Disposable that unsubscribes the handler when disposed.
Implementation of
Transport.onClose
onError()
onError(handler): Disposable;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:143
Subscribe to transport errors.
Parameters
| Parameter | Type | Description |
|---|---|---|
handler | (error) => void | Callback invoked when a transport-level error occurs. |
Returns
Disposable
A Disposable that unsubscribes the handler when disposed.
Implementation of
Transport.onError
onMessage()
onMessage(handler): Disposable;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:138
Subscribe to incoming messages.
Parameters
| Parameter | Type | Description |
|---|---|---|
handler | (message) => void | Callback invoked for each received message. |
Returns
Disposable
A Disposable that unsubscribes the handler when disposed.
Implementation of
Transport.onMessage
receive()
receive(raw): void;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:91
Push a raw payload received via the DO's webSocketMessage hook through the transport. The payload is JSON-parsed and dispatched to registered onMessage handlers; parse failures are routed to onError handlers.
Idempotent and safe to call after signalClose; messages arriving after close are dropped silently to match @lspeasy/core!WebSocketTransport behaviour.
Parameters
| Parameter | Type |
|---|---|
raw | string |
Returns
void
send()
send(message): Promise<void>;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:128
Send a message to the remote peer.
Parameters
| Parameter | Type | Description |
|---|---|---|
message | Message | The JSON-RPC message to send. |
Returns
Promise<void>
Throws
If the transport is not connected or an I/O error occurs.
Implementation of
Transport.send
signalClose()
signalClose(): void;Defined in: packages/lsp-server/src/cf-durable-object-transport.ts:114
Signal a connection close received via the DO's webSocketClose hook. Notifies registered onClose handlers exactly once; subsequent calls are no-ops.
Returns
void