Class LoroWebSocketAdapter

WebSocket adapter that runs in the extension (Node.js context). Manages WebSocket connection to Loro collaboration server.

Index

Constructors

constructor

new LoroWebSocketAdapter(
    adapterId: string,
    websocketUrl: string,
    webview: Webview,
): LoroWebSocketAdapter
Parameters
- adapterId: string
- websocketUrl: string
- webview: Webview
Returns LoroWebSocketAdapter
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:42

Properties

`Private` `Readonly`adapterId

adapterId: string

`Private`isDisposed

isDisposed: boolean = false

`Private` `Readonly`maxQueueSize

maxQueueSize: 1000

`Private`maxReconnectDelay

maxReconnectDelay: number = 2500

`Private`messageQueue

messageQueue: unknown[] = []

`Private`reconnectDelay

reconnectDelay: number = 100

`Private`reconnectTimer

reconnectTimer: Timeout = null

`Private` `Readonly`websocketUrl

websocketUrl: string

`Private` `Readonly`webview

webview: Webview

`Private`ws

ws: WebSocket = null

Methods

connect

connect(): void
Connect to the WebSocket server

Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:51

disconnect

disconnect(): void
Disconnect from the WebSocket server

Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:144

dispose

dispose(): void
Clean up resources

Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:227

`Private`flushMessageQueue

flushMessageQueue(): void
Flush queued messages to the WebSocket

Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:211

handleMessage

handleMessage(message: LoroMessage): void
Handle incoming messages from the webview
Parameters
- message: LoroMessage
Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:192

isConnected

isConnected(): boolean
Check if WebSocket is currently connected

Returns boolean
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:137

`Private`scheduleReconnect

scheduleReconnect(): void
Schedule reconnection with exponential backoff

Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:236

send

send(data: unknown): void
Send a message to the WebSocket server
Parameters
- data: unknown
Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:159

`Private`sendToWebview

sendToWebview(message: LoroMessage): void
Send a message to the webview
Parameters
- message: LoroMessage
Returns void
- Defined in src/services/collaboration/loroWebSocketAdapter.ts:256