Struct tokio_serde::Framed[−][src]

[+] Show declaration

pub struct Framed<Transport, Item, SinkItem, Codec> { /* fields omitted */ }

[−]

Adapts a transport to a value sink by serializing the values and to a stream of values by deserializing them.

It is expected that the buffers yielded by the supplied transport be framed. In other words, each yielded buffer must represent exactly one serialized value.

The provided transport will receive buffer values containing the serialized value. Each buffer contains exactly one value. This sink will be responsible for writing these buffers to an AsyncWrite using some sort of framing strategy.

The specific framing strategy is left up to the implementor. One option would be to use length_delimited provided by tokio-util.

Implementations

`impl<Transport, Item, SinkItem, Codec> Framed<Transport, Item, SinkItem, Codec>`[src][−]

`pub fn new(inner: Transport, codec: Codec) -> Self`[src][−]

Creates a new Framed with the given transport and codec.

`pub fn get_ref(&self) -> &Transport`[src][−]

Returns a reference to the underlying transport wrapped by Framed.

Note that care should be taken to not tamper with the underlying transport as it may corrupt the sequence of frames otherwise being worked with.

`pub fn get_mut(&mut self) -> &mut Transport`[src][−]

Returns a mutable reference to the underlying transport wrapped by Framed.

Note that care should be taken to not tamper with the underlying transport as it may corrupt the sequence of frames otherwise being worked with.

`pub fn into_inner(self) -> Transport`[src][−]

Consumes the Framed, returning its underlying transport.

Note that care should be taken to not tamper with the underlying transport as it may corrupt the sequence of frames otherwise being worked with.

Trait Implementations

`impl<Transport, Item, SinkItem, Codec> PinnedDrop for Framed<Transport, Item, SinkItem, Codec>`[src][+]

[+] Show hidden undocumented items

`unsafe fn drop(self: Pin<&mut Self>)`[src]

`impl<Transport, Item, SinkItem, Codec> Sink<SinkItem> for Framed<Transport, Item, SinkItem, Codec> where Transport: Sink<Bytes>, Codec: Serializer<SinkItem>, Codec::Error: Into<Transport::Error>,` [src][+]

[+] Show hidden undocumented items

`type Error = Transport::Error`

The type of value produced by the sink when an error occurs.

`fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>`[src][−]

`fn start_send(self: Pin<&mut Self>, item: SinkItem) -> Result<(), Self::Error>`[src][−]

`fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>`[src][−]

`fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>`[src][−]

`impl<Transport, Item, SinkItem, Codec> Stream for Framed<Transport, Item, SinkItem, Codec> where Transport: TryStream<Ok = BytesMut>, Transport::Error: From<Codec::Error>, BytesMut: From<Transport::Ok>, Codec: Deserializer<Item>,` [src][+]

[+] Show hidden undocumented items

`type Item = Result<Item, Transport::Error>`

Values yielded by the stream.

`fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>`[src][−]

`pub fn size_hint(&self) -> (usize, Option<usize>)`[src][−]

`impl<'pin, Transport, Item, SinkItem, Codec> Unpin for Framed<Transport, Item, SinkItem, Codec> where __Framed<'pin, Transport, Item, SinkItem, Codec>: Unpin,` [src]

`impl<Transport, Item, SinkItem, Codec> UnsafeUnpin for Framed<Transport, Item, SinkItem, Codec>`[src]

Auto Trait Implementations

`impl<Transport, Item, SinkItem, Codec> RefUnwindSafe for Framed<Transport, Item, SinkItem, Codec> where Codec: RefUnwindSafe, Item: RefUnwindSafe, SinkItem: RefUnwindSafe, Transport: RefUnwindSafe,`

`impl<Transport, Item, SinkItem, Codec> Send for Framed<Transport, Item, SinkItem, Codec> where Codec: Send, Item: Send, SinkItem: Send, Transport: Send,`

`impl<Transport, Item, SinkItem, Codec> Sync for Framed<Transport, Item, SinkItem, Codec> where Codec: Sync, Item: Sync, SinkItem: Sync, Transport: Sync,`

`impl<Transport, Item, SinkItem, Codec> UnwindSafe for Framed<Transport, Item, SinkItem, Codec> where Codec: UnwindSafe, Item: UnwindSafe, SinkItem: UnwindSafe, Transport: UnwindSafe,`

Blanket Implementations

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

[+] Show hidden undocumented items

`pub fn type_id(&self) -> TypeId`[src][−]

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

[+] Show hidden undocumented items

`pub fn borrow(&self) -> &T`[src][−]

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

[+] Show hidden undocumented items

`pub fn borrow_mut(&mut self) -> &mut T`[src][−]

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

[+] Show hidden undocumented items

`pub fn from(t: T) -> T`[src][−]

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

[+] Show hidden undocumented items

`pub fn into(self) -> U`[src][−]

`impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where E: From<Self::Error>, Fut: Future<Output = Result<Item, E>>, F: FnMut(U) -> Fut,` [src][−]

`pub fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where St: Stream<Item = Result<Item, Self::Error>>, F: FnMut(U) -> St,` [src][−]

`pub fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E,` [src][−]

`pub fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self::Error: Into<E>,` [src][−]

`pub fn buffer(self, capacity: usize) -> Buffer<Self, Item>`[src][−]

`pub fn close(&mut self) -> Close<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Item: Clone, Si: Sink<Item, Error = Self::Error>,` [src][−]

`pub fn flush(&mut self) -> Flush<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn send(&mut self, item: Item) -> Send<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn send_all<St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> where Self: Unpin, St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,` [src][−]

`pub fn left_sink<Si2>(self) -> Either<Self, Si2> where Si2: Sink<Item, Error = Self::Error>,` [src][−]

`pub fn right_sink<Si1>(self) -> Either<Si1, Self> where Si1: Sink<Item, Error = Self::Error>,` [src][−]

`pub fn poll_ready_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src][−]

`pub fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where Self: Unpin,` [src][−]

`pub fn poll_flush_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src][−]

`pub fn poll_close_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src][−]

`impl<T> StreamExt for T where T: Stream + ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn next(&mut self) -> Next<'_, Self> where Self: Unpin,` [src][−]

`pub fn into_future(self) -> StreamFuture<Self> where Self: Unpin,` [src][−]

`pub fn map<T, F>(self, f: F) -> Map<Self, F> where F: FnMut(Self::Item) -> T,` [src][−]

`pub fn enumerate(self) -> Enumerate<Self>`[src][−]

`pub fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut,` [src][−]

`pub fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where Fut: Future<Output = Option<T>>, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where Fut: Future, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn collect<C>(self) -> Collect<Self, C> where C: Default + Extend<Self::Item>,` [src][−]

`pub fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB> where Self: Stream<Item = (A, B)>, FromA: Default + Extend<A>, FromB: Default + Extend,` [src][−]

`pub fn concat(self) -> Concat<Self> where Self::Item: Extend<<Self::Item as IntoIterator>::Item>, Self::Item: IntoIterator, Self::Item: Default,` [src][−]

`pub fn cycle(self) -> Cycle<Self> where Self: Clone,` [src][−]

`pub fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where Fut: Future<Output = T>, F: FnMut(T, Self::Item) -> Fut,` [src][−]

`pub fn flatten(self) -> Flatten<Self> where Self::Item: Stream,` [src][−]

`pub fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where F: FnMut(Self::Item) -> U, U: Stream,` [src][−]

`pub fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F> where Fut: Future<Output = Option>, F: FnMut(&mut S, Self::Item) -> Fut,` [src][−]

`pub fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut,` [src][−]

`pub fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut,` [src][−]

`pub fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> where Fut: Future,` [src][−]

`pub fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where Fut: Future<Output = ()>, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F ) -> ForEachConcurrent<Self, Fut, F> where Fut: Future<Output = ()>, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn take(self, n: usize) -> Take<Self>`[src][−]

`pub fn skip(self, n: usize) -> Skip<Self>`[src][−]

`pub fn fuse(self) -> Fuse<Self>`[src][−]

`pub fn by_ref(&mut self) -> &mut Self`[src][−]

`pub fn catch_unwind(self) -> CatchUnwind<Self> where Self: UnwindSafe,` [src][−]

`pub fn boxed<'a>( self ) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a + Send, Global>> where Self: Send + 'a,` [src][−]

`pub fn boxed_local<'a>( self ) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a, Global>> where Self: 'a,` [src][−]

`pub fn buffered(self, n: usize) -> Buffered<Self> where Self::Item: Future,` [src][−]

`pub fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> where Self::Item: Future,` [src][−]

`pub fn zip<St>(self, other: St) -> Zip<Self, St> where St: Stream,` [src][−]

`pub fn chain<St>(self, other: St) -> Chain<Self, St> where St: Stream<Item = Self::Item>,` [src][−]

`pub fn peekable(self) -> Peekable<Self>`[src][−]

`pub fn chunks(self, capacity: usize) -> Chunks<Self>`[src][−]

`pub fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>`[src][−]

`pub fn forward<S>(self, sink: S) -> Forward<Self, S> where Self: TryStream, S: Sink<Self::Ok, Error = Self::Error>,` [src][−]

`pub fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>) where Self: Sink<Item>,` [src][−]

`pub fn inspect<F>(self, f: F) -> Inspect<Self, F> where F: FnMut(&Self::Item),` [src][−]

`pub fn left_stream(self) -> Either<Self, B> where B: Stream<Item = Self::Item>,` [src][−]

`pub fn right_stream(self) -> Either<B, Self> where B: Stream<Item = Self::Item>,` [src][−]

`pub fn poll_next_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>> where Self: Unpin,` [src][−]

`pub fn select_next_some(&mut self) -> SelectNextSome<'_, Self> where Self: Unpin + FusedStream,` [src][−]

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

[+] Show hidden undocumented items

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src][−]

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

[+] Show hidden undocumented items

`type Error = >::Error`

The type returned in the event of a conversion error.

`pub fn try_into(self) -> Result<U, >::Error>`[src][−]

`impl<S, T, E> TryStream for S where S: Stream<Item = Result<T, E>> + ?Sized,` [src][+]

[+] Show hidden undocumented items

`type Ok = T`

The type of successful values yielded by this future

`type Error = E`

The type of failures yielded by this future

`pub fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_> ) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>`[src][−]

`impl<S> TryStreamExt for S where S: TryStream + ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn err_into<E>(self) -> ErrInto<Self, E> where Self::Error: Into<E>,` [src][−]

`pub fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> where F: FnMut(Self::Ok) -> T,` [src][−]

`pub fn map_err<E, F>(self, f: F) -> MapErr<Self, F> where F: FnMut(Self::Error) -> E,` [src][−]

`pub fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F> where Fut: TryFuture<Error = Self::Error>, F: FnMut(Self::Ok) -> Fut,` [src][−]

`pub fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F> where Fut: TryFuture<Ok = Self::Ok>, F: FnMut(Self::Error) -> Fut,` [src][−]

`pub fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F> where F: FnMut(&Self::Ok),` [src][−]

`pub fn inspect_err<F>(self, f: F) -> InspectErr<Self, F> where F: FnMut(&Self::Error),` [src][−]

`pub fn into_stream(self) -> IntoStream<Self>`[src][−]

`pub fn try_next(&mut self) -> TryNext<'_, Self> where Self: Unpin,` [src][−]

`pub fn try_for_each<Fut, F>(self, f: F) -> TryForEach<Self, Fut, F> where Fut: TryFuture<Ok = (), Error = Self::Error>, F: FnMut(Self::Ok) -> Fut,` [src][−]

`pub fn try_skip_while<Fut, F>(self, f: F) -> TrySkipWhile<Self, Fut, F> where Fut: TryFuture<Ok = bool, Error = Self::Error>, F: FnMut(&Self::Ok) -> Fut,` [src][−]

`pub fn try_take_while<Fut, F>(self, f: F) -> TryTakeWhile<Self, Fut, F> where Fut: TryFuture<Ok = bool, Error = Self::Error>, F: FnMut(&Self::Ok) -> Fut,` [src][−]

`pub fn try_for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F ) -> TryForEachConcurrent<Self, Fut, F> where Fut: Future<Output = Result<(), Self::Error>>, F: FnMut(Self::Ok) -> Fut,` [src][−]

`pub fn try_collect<C>(self) -> TryCollect<Self, C> where C: Default + Extend<Self::Ok>,` [src][−]

`pub fn try_filter<Fut, F>(self, f: F) -> TryFilter<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Ok) -> Fut,` [src][−]

`pub fn try_filter_map<Fut, F, T>(self, f: F) -> TryFilterMap<Self, Fut, F> where Fut: TryFuture<Ok = Option<T>, Error = Self::Error>, F: FnMut(Self::Ok) -> Fut,` [src][−]

`pub fn try_flatten(self) -> TryFlatten<Self> where Self::Ok: TryStream, <Self::Ok as TryStream>::Error: From<Self::Error>,` [src][−]

`pub fn try_fold<T, Fut, F>(self, init: T, f: F) -> TryFold<Self, Fut, T, F> where Fut: TryFuture<Ok = T, Error = Self::Error>, F: FnMut(T, Self::Ok) -> Fut,` [src][−]

`pub fn try_concat(self) -> TryConcat<Self> where Self::Ok: Extend<<Self::Ok as IntoIterator>::Item>, Self::Ok: IntoIterator, Self::Ok: Default,` [src][−]

`pub fn try_buffer_unordered(self, n: usize) -> TryBufferUnordered<Self> where Self::Ok: TryFuture, <Self::Ok as TryFuture>::Error == Self::Error,` [src][−]

Struct tokio_serde::Framed[−][src]

Implementations

impl<Transport, Item, SinkItem, Codec> Framed<Transport, Item, SinkItem, Codec>[src][−]

pub fn new(inner: Transport, codec: Codec) -> Self[src][−]

pub fn get_ref(&self) -> &Transport[src][−]

pub fn get_mut(&mut self) -> &mut Transport[src][−]

pub fn into_inner(self) -> Transport[src][−]

Trait Implementations

impl<Transport, Item, SinkItem, Codec> PinnedDrop for Framed<Transport, Item, SinkItem, Codec>[src][+]

unsafe fn drop(self: Pin<&mut Self>)[src]

impl<Transport, Item, SinkItem, Codec> Sink<SinkItem> for Framed<Transport, Item, SinkItem, Codec> where Transport: Sink<Bytes>, Codec: Serializer<SinkItem>, Codec::Error: Into<Transport::Error>, [src][+]

type Error = Transport::Error

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>[src][−]

fn start_send(self: Pin<&mut Self>, item: SinkItem) -> Result<(), Self::Error>[src][−]

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>[src][−]

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>[src][−]

impl<Transport, Item, SinkItem, Codec> Stream for Framed<Transport, Item, SinkItem, Codec> where Transport: TryStream<Ok = BytesMut>, Transport::Error: From<Codec::Error>, BytesMut: From<Transport::Ok>, Codec: Deserializer<Item>, [src][+]

type Item = Result<Item, Transport::Error>

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>[src][−]

pub fn size_hint(&self) -> (usize, Option<usize>)[src][−]

impl<'pin, Transport, Item, SinkItem, Codec> Unpin for Framed<Transport, Item, SinkItem, Codec> where __Framed<'pin, Transport, Item, SinkItem, Codec>: Unpin, [src]

impl<Transport, Item, SinkItem, Codec> UnsafeUnpin for Framed<Transport, Item, SinkItem, Codec>[src]

Auto Trait Implementations

impl<Transport, Item, SinkItem, Codec> RefUnwindSafe for Framed<Transport, Item, SinkItem, Codec> where Codec: RefUnwindSafe, Item: RefUnwindSafe, SinkItem: RefUnwindSafe, Transport: RefUnwindSafe,

impl<Transport, Item, SinkItem, Codec> Send for Framed<Transport, Item, SinkItem, Codec> where Codec: Send, Item: Send, SinkItem: Send, Transport: Send,

impl<Transport, Item, SinkItem, Codec> Sync for Framed<Transport, Item, SinkItem, Codec> where Codec: Sync, Item: Sync, SinkItem: Sync, Transport: Sync,

impl<Transport, Item, SinkItem, Codec> UnwindSafe for Framed<Transport, Item, SinkItem, Codec> where Codec: UnwindSafe, Item: UnwindSafe, SinkItem: UnwindSafe, Transport: UnwindSafe,

Blanket Implementations

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

pub fn type_id(&self) -> TypeId[src][−]

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

pub fn borrow(&self) -> &T[src][−]

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

pub fn borrow_mut(&mut self) -> &mut T[src][−]

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

pub fn from(t: T) -> T[src][−]

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

pub fn into(self) -> U[src][−]

impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized, [src][+]

pub fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where E: From<Self::Error>, Fut: Future<Output = Result<Item, E>>, F: FnMut(U) -> Fut, [src][−]

pub fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where St: Stream<Item = Result<Item, Self::Error>>, F: FnMut(U) -> St, [src][−]

pub fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E, [src][−]

pub fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self::Error: Into<E>, [src][−]

pub fn buffer(self, capacity: usize) -> Buffer<Self, Item>[src][−]

pub fn close(&mut self) -> Close<'_, Self, Item> where Self: Unpin, [src][−]

pub fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Item: Clone, Si: Sink<Item, Error = Self::Error>, [src][−]

pub fn flush(&mut self) -> Flush<'_, Self, Item> where Self: Unpin, [src][−]

pub fn send(&mut self, item: Item) -> Send<'_, Self, Item> where Self: Unpin, [src][−]

pub fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> where Self: Unpin, [src][−]

pub fn send_all<St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> where Self: Unpin, St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized, [src][−]

pub fn left_sink<Si2>(self) -> Either<Self, Si2> where Si2: Sink<Item, Error = Self::Error>, [src][−]

pub fn right_sink<Si1>(self) -> Either<Si1, Self> where Si1: Sink<Item, Error = Self::Error>, [src][−]

pub fn poll_ready_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> where Self: Unpin, [src][−]

pub fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where Self: Unpin, [src][−]

pub fn poll_flush_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> where Self: Unpin, [src][−]

pub fn poll_close_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> where Self: Unpin, [src][−]

impl<T> StreamExt for T where T: Stream + ?Sized, [src][+]

pub fn next(&mut self) -> Next<'_, Self> where Self: Unpin, [src][−]

pub fn into_future(self) -> StreamFuture<Self> where Self: Unpin, [src][−]

pub fn map<T, F>(self, f: F) -> Map<Self, F> where F: FnMut(Self::Item) -> T, [src][−]

pub fn enumerate(self) -> Enumerate<Self>[src][−]

pub fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut, [src][−]

pub fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where Fut: Future<Output = Option<T>>, F: FnMut(Self::Item) -> Fut, [src][−]

pub fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where Fut: Future, F: FnMut(Self::Item) -> Fut, [src][−]

pub fn collect<C>(self) -> Collect<Self, C> where C: Default + Extend<Self::Item>, [src][−]

pub fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB> where Self: Stream<Item = (A, B)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, [src][−]

pub fn concat(self) -> Concat<Self> where Self::Item: Extend<<Self::Item as IntoIterator>::Item>, Self::Item: IntoIterator, Self::Item: Default, [src][−]

pub fn cycle(self) -> Cycle<Self> where Self: Clone, [src][−]

pub fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where Fut: Future<Output = T>, F: FnMut(T, Self::Item) -> Fut, [src][−]

pub fn flatten(self) -> Flatten<Self> where Self::Item: Stream, [src][−]

pub fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where F: FnMut(Self::Item) -> U, U: Stream, [src][−]

pub fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F> where Fut: Future<Output = Option<B>>, F: FnMut(&mut S, Self::Item) -> Fut, [src][−]

pub fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut, [src][−]

pub fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut, [src][−]

pub fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> where Fut: Future, [src][−]

pub fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where Fut: Future<Output = ()>, F: FnMut(Self::Item) -> Fut, [src][−]

pub fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F) -> ForEachConcurrent<Self, Fut, F> where Fut: Future<Output = ()>, F: FnMut(Self::Item) -> Fut, [src][−]

pub fn take(self, n: usize) -> Take<Self>[src][−]

pub fn skip(self, n: usize) -> Skip<Self>[src][−]

pub fn fuse(self) -> Fuse<Self>[src][−]

`impl<Transport, Item, SinkItem, Codec> Framed<Transport, Item, SinkItem, Codec>`[src][−]

`pub fn new(inner: Transport, codec: Codec) -> Self`[src][−]

`pub fn get_ref(&self) -> &Transport`[src][−]

`pub fn get_mut(&mut self) -> &mut Transport`[src][−]

`pub fn into_inner(self) -> Transport`[src][−]

`impl<Transport, Item, SinkItem, Codec> PinnedDrop for Framed<Transport, Item, SinkItem, Codec>`[src][+]

`unsafe fn drop(self: Pin<&mut Self>)`[src]

`impl<Transport, Item, SinkItem, Codec> Sink<SinkItem> for Framed<Transport, Item, SinkItem, Codec> where Transport: Sink<Bytes>, Codec: Serializer<SinkItem>, Codec::Error: Into<Transport::Error>,` [src][+]

`type Error = Transport::Error`

`fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>`[src][−]

`fn start_send(self: Pin<&mut Self>, item: SinkItem) -> Result<(), Self::Error>`[src][−]

`fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>`[src][−]

`fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>`[src][−]

`impl<Transport, Item, SinkItem, Codec> Stream for Framed<Transport, Item, SinkItem, Codec> where Transport: TryStream<Ok = BytesMut>, Transport::Error: From<Codec::Error>, BytesMut: From<Transport::Ok>, Codec: Deserializer<Item>,` [src][+]

`type Item = Result<Item, Transport::Error>`

`fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>`[src][−]

`pub fn size_hint(&self) -> (usize, Option<usize>)`[src][−]

`impl<'pin, Transport, Item, SinkItem, Codec> Unpin for Framed<Transport, Item, SinkItem, Codec> where __Framed<'pin, Transport, Item, SinkItem, Codec>: Unpin,` [src]

`impl<Transport, Item, SinkItem, Codec> UnsafeUnpin for Framed<Transport, Item, SinkItem, Codec>`[src]

`impl<Transport, Item, SinkItem, Codec> RefUnwindSafe for Framed<Transport, Item, SinkItem, Codec> where Codec: RefUnwindSafe, Item: RefUnwindSafe, SinkItem: RefUnwindSafe, Transport: RefUnwindSafe,`

`impl<Transport, Item, SinkItem, Codec> Send for Framed<Transport, Item, SinkItem, Codec> where Codec: Send, Item: Send, SinkItem: Send, Transport: Send,`

`impl<Transport, Item, SinkItem, Codec> Sync for Framed<Transport, Item, SinkItem, Codec> where Codec: Sync, Item: Sync, SinkItem: Sync, Transport: Sync,`

`impl<Transport, Item, SinkItem, Codec> UnwindSafe for Framed<Transport, Item, SinkItem, Codec> where Codec: UnwindSafe, Item: UnwindSafe, SinkItem: UnwindSafe, Transport: UnwindSafe,`

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

`pub fn type_id(&self) -> TypeId`[src][−]

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

`pub fn borrow(&self) -> &T`[src][−]

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

`pub fn borrow_mut(&mut self) -> &mut T`[src][−]

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

`pub fn from(t: T) -> T`[src][−]

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

`pub fn into(self) -> U`[src][−]

`impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized,` [src][+]

`pub fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where E: From<Self::Error>, Fut: Future<Output = Result<Item, E>>, F: FnMut(U) -> Fut,` [src][−]

`pub fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where St: Stream<Item = Result<Item, Self::Error>>, F: FnMut(U) -> St,` [src][−]

`pub fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E,` [src][−]

`pub fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self::Error: Into<E>,` [src][−]

`pub fn buffer(self, capacity: usize) -> Buffer<Self, Item>`[src][−]

`pub fn close(&mut self) -> Close<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Item: Clone, Si: Sink<Item, Error = Self::Error>,` [src][−]

`pub fn flush(&mut self) -> Flush<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn send(&mut self, item: Item) -> Send<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> where Self: Unpin,` [src][−]

`pub fn send_all<St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> where Self: Unpin, St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,` [src][−]

`pub fn left_sink<Si2>(self) -> Either<Self, Si2> where Si2: Sink<Item, Error = Self::Error>,` [src][−]

`pub fn right_sink<Si1>(self) -> Either<Si1, Self> where Si1: Sink<Item, Error = Self::Error>,` [src][−]

`pub fn poll_ready_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src][−]

`pub fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where Self: Unpin,` [src][−]

`pub fn poll_flush_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src][−]

`pub fn poll_close_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src][−]

`impl<T> StreamExt for T where T: Stream + ?Sized,` [src][+]

`pub fn next(&mut self) -> Next<'_, Self> where Self: Unpin,` [src][−]

`pub fn into_future(self) -> StreamFuture<Self> where Self: Unpin,` [src][−]

`pub fn map<T, F>(self, f: F) -> Map<Self, F> where F: FnMut(Self::Item) -> T,` [src][−]

`pub fn enumerate(self) -> Enumerate<Self>`[src][−]

`pub fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut,` [src][−]

`pub fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where Fut: Future<Output = Option<T>>, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where Fut: Future, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn collect<C>(self) -> Collect<Self, C> where C: Default + Extend<Self::Item>,` [src][−]

`pub fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB> where Self: Stream<Item = (A, B)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>,` [src][−]

`pub fn concat(self) -> Concat<Self> where Self::Item: Extend<<Self::Item as IntoIterator>::Item>, Self::Item: IntoIterator, Self::Item: Default,` [src][−]

`pub fn cycle(self) -> Cycle<Self> where Self: Clone,` [src][−]

`pub fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where Fut: Future<Output = T>, F: FnMut(T, Self::Item) -> Fut,` [src][−]

`pub fn flatten(self) -> Flatten<Self> where Self::Item: Stream,` [src][−]

`pub fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where F: FnMut(Self::Item) -> U, U: Stream,` [src][−]

`pub fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F> where Fut: Future<Output = Option<B>>, F: FnMut(&mut S, Self::Item) -> Fut,` [src][−]

`pub fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut,` [src][−]

`pub fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where Fut: Future<Output = bool>, F: FnMut(&Self::Item) -> Fut,` [src][−]

`pub fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> where Fut: Future,` [src][−]

`pub fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where Fut: Future<Output = ()>, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F ) -> ForEachConcurrent<Self, Fut, F> where Fut: Future<Output = ()>, F: FnMut(Self::Item) -> Fut,` [src][−]

`pub fn take(self, n: usize) -> Take<Self>`[src][−]

`pub fn skip(self, n: usize) -> Skip<Self>`[src][−]

`pub fn fuse(self) -> Fuse<Self>`[src][−]

`pub fn by_ref(&mut self) -> &mut Self`[src][−]

`pub fn catch_unwind(self) -> CatchUnwind<Self> where Self: UnwindSafe,` [src][−]

`pub fn boxed<'a>( self ) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a + Send, Global>> where Self: Send + 'a,` [src][−]

`pub fn boxed_local<'a>( self ) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a, Global>> where Self: 'a,` [src][−]

`pub fn buffered(self, n: usize) -> Buffered<Self> where Self::Item: Future,` [src][−]