[−][src]Trait amadeus::par_stream::StreamTaskAsync
Associated Types
type Item
Required methods
fn poll_run(
self: Pin<&mut Self>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = Self::Item>>
) -> Poll<()>
self: Pin<&mut Self>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = Self::Item>>
) -> Poll<()>
Implementations on Foreign Types
impl<'_, T> StreamTaskAsync for &'_ mut T where
T: StreamTaskAsync + Unpin + ?Sized,
[src]
T: StreamTaskAsync + Unpin + ?Sized,
type Item = <T as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut &'_ mut T>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <&'_ mut T as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut &'_ mut T>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <&'_ mut T as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<P> StreamTaskAsync for Pin<P> where
P: DerefMut + Unpin,
<P as Deref>::Target: StreamTaskAsync,
[src]
P: DerefMut + Unpin,
<P as Deref>::Target: StreamTaskAsync,
type Item = <<P as Deref>::Target as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut Pin<P>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <Pin<P> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Pin<P>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <Pin<P> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<A, B> StreamTaskAsync for Sum2<A, B> where
A: StreamTaskAsync,
B: StreamTaskAsync<Item = <A as StreamTaskAsync>::Item>,
[src]
A: StreamTaskAsync,
B: StreamTaskAsync<Item = <A as StreamTaskAsync>::Item>,
type Item = <A as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut Sum2<A, B>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <Sum2<A, B> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Sum2<A, B>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <Sum2<A, B> as StreamTaskAsync>::Item>>
) -> Poll<()>
Implementors
impl StreamTaskAsync for Never
[src]
type Item = Never
fn poll_run(
self: Pin<&mut Never>,
_cx: &mut Context,
_sink: Pin<&mut impl Sink<Item = <Never as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Never>,
_cx: &mut Context,
_sink: Pin<&mut impl Sink<Item = <Never as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<A, B> StreamTaskAsync for ChainTask<A, B> where
A: StreamTaskAsync,
B: StreamTaskAsync<Item = <A as StreamTaskAsync>::Item>,
[src]
A: StreamTaskAsync,
B: StreamTaskAsync<Item = <A as StreamTaskAsync>::Item>,
type Item = <A as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut ChainTask<A, B>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <ChainTask<A, B> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut ChainTask<A, B>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <ChainTask<A, B> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<C, F> StreamTaskAsync for InspectTask<C, F> where
C: StreamTaskAsync,
F: FnMut(&<C as StreamTaskAsync>::Item) + Clone,
[src]
C: StreamTaskAsync,
F: FnMut(&<C as StreamTaskAsync>::Item) + Clone,
type Item = <C as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut InspectTask<C, F>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <InspectTask<C, F> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut InspectTask<C, F>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <InspectTask<C, F> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<C, F> StreamTaskAsync for UpdateTask<C, F> where
C: StreamTaskAsync,
F: FnMut(&mut <C as StreamTaskAsync>::Item) + Clone,
[src]
C: StreamTaskAsync,
F: FnMut(&mut <C as StreamTaskAsync>::Item) + Clone,
type Item = <C as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut UpdateTask<C, F>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <UpdateTask<C, F> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut UpdateTask<C, F>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <UpdateTask<C, F> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<C, F, Fut> StreamTaskAsync for FilterStreamTaskAsync<C, F, <C as StreamTaskAsync>::Item, Fut> where
C: StreamTaskAsync,
F: FnMut(&<C as StreamTaskAsync>::Item) -> Fut + Clone,
Fut: Future<Output = bool>,
[src]
C: StreamTaskAsync,
F: FnMut(&<C as StreamTaskAsync>::Item) -> Fut + Clone,
Fut: Future<Output = bool>,
type Item = <C as StreamTaskAsync>::Item
fn poll_run(
self: Pin<&mut FilterStreamTaskAsync<C, F, <C as StreamTaskAsync>::Item, Fut>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <FilterStreamTaskAsync<C, F, <C as StreamTaskAsync>::Item, Fut> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut FilterStreamTaskAsync<C, F, <C as StreamTaskAsync>::Item, Fut>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <FilterStreamTaskAsync<C, F, <C as StreamTaskAsync>::Item, Fut> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<C, F, R> StreamTaskAsync for FlatMapStreamTaskAsync<C, F, R> where
C: StreamTaskAsync,
F: Clone + FnMut(<C as StreamTaskAsync>::Item) -> R,
R: Stream,
[src]
C: StreamTaskAsync,
F: Clone + FnMut(<C as StreamTaskAsync>::Item) -> R,
R: Stream,
type Item = <R as Stream>::Item
fn poll_run(
self: Pin<&mut FlatMapStreamTaskAsync<C, F, R>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <FlatMapStreamTaskAsync<C, F, R> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut FlatMapStreamTaskAsync<C, F, R>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <FlatMapStreamTaskAsync<C, F, R> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<C, F, R> StreamTaskAsync for MapTask<C, F> where
C: StreamTaskAsync,
F: FnMut(<C as StreamTaskAsync>::Item) -> R + Clone,
[src]
C: StreamTaskAsync,
F: FnMut(<C as StreamTaskAsync>::Item) -> R + Clone,
type Item = R
fn poll_run(
self: Pin<&mut MapTask<C, F>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <MapTask<C, F> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut MapTask<C, F>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <MapTask<C, F> as StreamTaskAsync>::Item>>
) -> Poll<()>
impl<I, T, E, U> StreamTaskAsync for IntoTask<I, U> where
I: StreamTaskAsync<Item = Result<T, E>>,
T: Into<U>,
[src]
I: StreamTaskAsync<Item = Result<T, E>>,
T: Into<U>,
type Item = Result<U, E>
fn poll_run(
self: Pin<&mut Self>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = Self::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = Self::Item>>
) -> Poll<()>
impl<T> StreamTaskAsync for IterStreamTask<T>
[src]
type Item = T
fn poll_run(
self: Pin<&mut IterStreamTask<T>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <IterStreamTask<T> as StreamTaskAsync>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut IterStreamTask<T>>,
cx: &mut Context,
sink: Pin<&mut impl Sink<Item = <IterStreamTask<T> as StreamTaskAsync>::Item>>
) -> Poll<()>