Skip to main content

commit_journal

Function commit_journal 

Source
pub fn commit_journal<E: Clone>(
    batches: impl IntoIterator<Item = (StreamId, Vec<NewEvent<E>>)>,
) -> Result<Vec<StoredEvent<E>>>
Expand description

Commits independent stream batches into one zero-based journal.

Global positions are assigned from the store length. Each new stream starts at version 0, so a producer must not copy the global counter onto a fresh run stream.

ยงErrors

Returns the same version, duplicate-event, or capacity errors as EventStore::append_owned.