pub struct MultiResourceWriterStream<O, Opener: MultiResourceWriterOpener<O>, P> { /* private fields */ }Expand description
The crate::ItemStream half of a MultiResourceWriter.
Trait Implementations§
Source§impl<O, Opener, P> ItemStream for MultiResourceWriterStream<O, Opener, P>where
O: Sync + 'static,
Opener: MultiResourceWriterOpener<O> + 'static,
P: RolloverPolicy + 'static,
impl<O, Opener, P> ItemStream for MultiResourceWriterStream<O, Opener, P>where
O: Sync + 'static,
Opener: MultiResourceWriterOpener<O> + 'static,
P: RolloverPolicy + 'static,
Source§async fn open(
&self,
context: StreamOpenContext<'_>,
) -> Result<StreamOpenOutcome, StreamOpenError>
async fn open( &self, context: StreamOpenContext<'_>, ) -> Result<StreamOpenOutcome, StreamOpenError>
Restores last committed state, or begins initial execution. Read more
Source§async fn update(
&self,
context: StreamUpdateContext<'_>,
) -> Result<ComponentStateEnvelope, StreamUpdateError>
async fn update( &self, context: StreamUpdateContext<'_>, ) -> Result<ComponentStateEnvelope, StreamUpdateError>
Produces the candidate component-state envelope for the chunk about
to commit. Read more
Source§async fn close(
&self,
context: StreamCloseContext<'_>,
) -> Result<StreamCloseOutcome, StreamCloseError>
async fn close( &self, context: StreamCloseContext<'_>, ) -> Result<StreamCloseOutcome, StreamCloseError>
Runs once for every stream that opened successfully in this step
attempt. Read more
Auto Trait Implementations§
impl<O, Opener, P> !RefUnwindSafe for MultiResourceWriterStream<O, Opener, P>
impl<O, Opener, P> !UnwindSafe for MultiResourceWriterStream<O, Opener, P>
impl<O, Opener, P> Freeze for MultiResourceWriterStream<O, Opener, P>
impl<O, Opener, P> Send for MultiResourceWriterStream<O, Opener, P>
impl<O, Opener, P> Sync for MultiResourceWriterStream<O, Opener, P>
impl<O, Opener, P> Unpin for MultiResourceWriterStream<O, Opener, P>
impl<O, Opener, P> UnsafeUnpin for MultiResourceWriterStream<O, Opener, P>where
Arc<WriterShared<O, Opener, P>>: UnsafeUnpin,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more