(message: UserMessage, localId?: string)
| 348 | } |
| 349 | |
| 350 | private enqueueUserMessage(message: UserMessage, localId?: string): void { |
| 351 | if (this.pendingMessageCallback) { |
| 352 | this.pendingMessageCallback(message, localId) |
| 353 | } else { |
| 354 | this.pendingMessages.push({ message, localId }) |
| 355 | } |
| 356 | } |
| 357 | |
| 358 | private handleIncomingMessage(message: { id?: string; seq?: number; localId?: string | null; content: unknown }): void { |
| 359 | if (!this.incomingFilter.accept({ id: message.id, seq: message.seq })) { |
no test coverage detected