Trait laminarmq_io::io_types::StreamAppend

source · 
pub trait StreamAppend: SizedEntity + FallibleEntity {
    // Required method
    fn append_stream<XE, X>(
        &mut self,
        stream: &mut X,
        opts: StreamAppendOpts<Self::Size>,
    ) -> impl Future<Output = StreamAppendResult<Self::Position, Self::Size, Self::Error, XE>>
       where X: Stream<OwnedLender<Result<Bytes, XE>>> + Unpin;
}

Required Methods§

source

fn append_stream<XE, X>( &mut self, stream: &mut X, opts: StreamAppendOpts<Self::Size>, ) -> impl Future<Output = StreamAppendResult<Self::Position, Self::Size, Self::Error, XE>>
where X: Stream<OwnedLender<Result<Bytes, XE>>> + Unpin,

Object Safety§

This trait is not object safe.

Implementors§