pub struct MultiResourceReaderStream<I, O: MultiResourceReaderOpener<I>> { /* private fields */ }Expand description
The crate::ItemStream half of a MultiResourceReader.
Trait Implementations§
Source§impl<I, O> ItemStream for MultiResourceReaderStream<I, O>where
I: Send + 'static,
O: MultiResourceReaderOpener<I> + 'static,
impl<I, O> ItemStream for MultiResourceReaderStream<I, O>where
I: Send + 'static,
O: MultiResourceReaderOpener<I> + '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<I, O> !RefUnwindSafe for MultiResourceReaderStream<I, O>
impl<I, O> !UnwindSafe for MultiResourceReaderStream<I, O>
impl<I, O> Freeze for MultiResourceReaderStream<I, O>
impl<I, O> Send for MultiResourceReaderStream<I, O>
impl<I, O> Sync for MultiResourceReaderStream<I, O>
impl<I, O> Unpin for MultiResourceReaderStream<I, O>
impl<I, O> UnsafeUnpin for MultiResourceReaderStream<I, O>where
Arc<ReaderShared<I, O>>: 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