[][src]Struct nakadion::components::committer::CommitHandle

pub struct CommitHandle { /* fields omitted */ }

Handle to send commit messages to the background task.

The background task will stop, once the last handle is dropped.

Implementations

impl CommitHandle[src]

pub fn commit(&self, to_commit: CommitItem) -> Result<(), CommitItem>[src]

Commit the given cursor with additional information packed in the struct CommitData.

Fails if the data could not be send which means that the backend is gone. The appropriate action is then to stop streaming.

Trait Implementations

impl Clone for CommitHandle[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,