Struct ResolvedStreams 

pub struct ResolvedStreams<'a, B: EventStreamBackend> {
    pub cursor: u64,
    pub current: StreamId,
    /* private fields */
}

Streams that are synchronized correctly after a MultiStream::resolve is called.

Fields

cursor: u64

The cursor on the current stream.

This cursor should be use for new allocations happening on the current stream.

current: StreamId

The current stream where new tasks can be sent safely.

Implementations

impl<'a, B: EventStreamBackend> ResolvedStreams<'a, B>

pub fn get(&mut self, stream_id: &StreamId) -> &mut B::Stream

Get the stream associated to the given stream_id.

pub fn current(&mut self) -> &mut B::Stream

Get the stream associated to the current stream_id.

pub fn current_and_failures(&mut self) -> (&mut B::Stream, &mut ErrorGraph)

The current stream and the device’s failure store together, for the paths that hand the store to the stream’s memory manager — every reserve, bind and cleanup, since those are where slices shed the failures they carry.

pub fn get_and_failures( &mut self, stream_id: &StreamId, ) -> (&mut B::Stream, &mut ErrorGraph)

current_and_failures for the stream at stream_id.

pub fn taint<'b>( &mut self, error: ServerError, written: impl Iterator<Item = &'b BufferBinding>, )

Taint every allocation in written with error — see base::taint.

pub fn written<'b>(&mut self, written: impl Iterator<Item = &'b BufferBinding>)

Release the failure on every allocation in written — see base::written.

pub fn gc(&mut self, gc: GcTask<B>)

Enqueue a task to be cleaned.

Trait Implementations

impl<'a, B: EventStreamBackend> Drop for ResolvedStreams<'a, B>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.