Interface ModelCommitBatchingClient

All Known Implementing Classes:

WebSocketEventStoreClient

public interface ModelCommitBatchingClient

Allows already-prepared, independent model commits to enter the websocket queue as one batch.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ModelCommitBatchingClient.ModelCommitBatch
static final record	ModelCommitBatchingClient.ModelCommitCompletion	Request-owned context for completing model commits in the transport result batch that contains them.
static interface	ModelCommitBatchingClient.ModelCommitResultProcessor	Completes aligned model results and their request-owned contexts as one unit.

Method Summary

Modifier and Type	Method	Description
ModelCommitBatchingClient.ModelCommitBatch	beginModelCommitBatch(int capacity)
default ModelCommitBatchingClient.ModelCommitBatch	beginReadyModelCommitBatch()	Begins a transport batch for commits that become ready independently during handler execution.

Method Details

beginModelCommitBatch

ModelCommitBatchingClient.ModelCommitBatch beginModelCommitBatch(int capacity)

beginReadyModelCommitBatch

default ModelCommitBatchingClient.ModelCommitBatch beginReadyModelCommitBatch()

Begins a transport batch for commits that become ready independently during handler execution.

Unlike beginModelCommitBatch(int), this batch does not imply that commit execution waits for the batch boundary. Implementations may release bounded full chunks immediately and use ModelCommitBatchingClient.ModelCommitBatch.flush() only to release the remaining tail. Returning null retains individual commit transport.