Struct eventstore::WriteEvents

pub struct WriteEvents { /* fields omitted */ }

Command that sends events to a given stream.

Implementations

impl WriteEvents

pub fn expected_version(self, version: ExpectedVersion) -> Self

Asks the server to check that the stream receiving the event is at the given expected version. Default: Credentials::Any.

pub fn credentials(self, creds: Credentials) -> Self

Performs the command with the given credentials.

pub async fn send_event(
    self,
    event: EventData
) -> Result<Result<WriteResult, WrongExpectedVersion>>

Sends asynchronously the write command to the server.

pub async fn send_iter<I>(
    self,
    events: I
) -> Result<Result<WriteResult, WrongExpectedVersion>> where
    I: IntoIterator<Item = EventData> + Send + Sync,
    <I as IntoIterator>::IntoIter: Send + Sync + 'static, 

Sends asynchronously the write command to the server.

pub async fn send<S>(
    self,
    events: S
) -> Result<Result<WriteResult, WrongExpectedVersion>> where
    S: Stream<Item = EventData> + Send + Sync + 'static, 

Sends asynchronously the write command to the server.