Highest cumulative ACK watermark. When durable ACK is being tracked this advances only after durability; otherwise it follows ordinary OK ACKs.
Highest stable frame sequence published by this session/transport.
Prompts the server to publish its latest durable-ingress watermarks. Node transports use a WebSocket PING; browsers send the protocol-level table-less durable-ACK poll frame. Browser completion means the control frame was published; durable progress arrives independently because the server may withhold its cumulative OK while a transaction remains open.
Publishes one pre-encoded frame without allocating an ACK waiter. Applications can observe later acceptance through progress callbacks.
Encodes and publishes tables without waiting for their server ACK. With Node store-and-forward this resolves only after every frame is durable in the local journal; browser and non-persistent transports resolve after the WebSocket accepts the frames.
Publishes tables with the automatic connection-scoped symbol dictionary. After a replay dictionary persistence error, retries use full inline symbols and no longer depend on the failed sidecar.
InternalRegisters runtime-specific cleanup owned by this session.
Starts one pre-encoded frame with independent publication and ACKs.
Sends tables using the session's connection-scoped symbol dictionary. String symbol values are assigned stable IDs automatically. If a replay dictionary append fails, that call rejects with QwpReplayDictionaryPersistenceError; retrying uses full inline symbols.
Delta-dictionary variant of sendTablesWithPublication().
The synchronous publication API cannot wait to plan behind another delta operation, so overlapping calls reject. Use sendTablesDelta() or publishTablesDelta() when operations may be started concurrently; those asynchronous APIs serialize planning through the publication boundary.
Starts an ingress batch and exposes local publication separately from its server ACK. High-level senders use this boundary to retain retryable rows until a persistent replay journal owns the complete logical batch.
Waits independently for the cumulative frame ACK watermark. A negative target is already satisfied, but still surfaces a latched session error.
Waits until a durable ACK covers every table transaction in an OK ACK. Durable tracking must have been enabled with durableAckKeepaliveMs.
StaticconnectOptionalsignal: AbortSignalCancels a first connect that is still negotiating. The reconnect loop
owns its own controller, but the initial attempt bypasses it -- it is
either handed in as initialConnection or awaited directly below -- so
without this a close() during the first connect left the socket and its
deadline alive for the full connect/auth timeout.
Connection-scoped ingress sequencer.
One promise is registered before each WebSocket send, preventing a fast ACK from racing its waiter. Calls are serialized to preserve the server's zero-based wire sequence. Successful ACKs are cumulative, so an ACK for sequence N resolves every outstanding send through N.