[−][src]Trait amadeus_core::sink::Sink
Associated Types
type Item
Required methods
fn poll_forward(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
Implementations on Foreign Types
impl<P> Sink for Pin<P> where
P: DerefMut + Unpin,
P::Target: Sink,
[src]
P: DerefMut + Unpin,
P::Target: Sink,
type Item = <P::Target as Sink>::Item
fn poll_forward(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
impl<'_, T: ?Sized> Sink for &'_ mut T where
T: Sink + Unpin,
[src]
T: Sink + Unpin,
type Item = T::Item
fn poll_forward(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
Implementors
impl<'a, F, I, Fut, Item> Sink for SinkFilter<'a, F, I, Item, Fut> where
F: FnMut(&Item) -> Fut,
Fut: Future<Output = bool>,
I: Sink<Item = Item>,
[src]
F: FnMut(&Item) -> Fut,
Fut: Future<Output = bool>,
I: Sink<Item = Item>,
type Item = Item
fn poll_forward(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
impl<'a, F, I, R, Fut, Item> Sink for SinkFlatMap<'a, F, I, Fut, R, Item> where
F: FnMut(Item) -> Fut,
Fut: Stream<Item = R>,
I: Sink<Item = R>,
[src]
F: FnMut(Item) -> Fut,
Fut: Stream<Item = R>,
I: Sink<Item = R>,
type Item = Item
fn poll_forward(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
impl<'a, F, I, R, Fut, Item> Sink for SinkThen<'a, F, I, Fut, R, Item> where
F: FnMut(Item) -> Fut,
Fut: Future<Output = R>,
I: Sink<Item = R>,
[src]
F: FnMut(Item) -> Fut,
Fut: Future<Output = R>,
I: Sink<Item = R>,
type Item = Item
fn poll_forward(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>
impl<F, I, R, Item> Sink for SinkMap<F, I, R, Item> where
F: FnMut(Item) -> R,
I: Sink<Item = R>,
[src]
F: FnMut(Item) -> R,
I: Sink<Item = R>,