Trait teloxide::update_listeners::AsUpdateStream

pub trait AsUpdateStream<'a> {
    type StreamErr;
    type Stream: Stream<Item = Result<Update, Self::StreamErr>> + Send + 'a;

    fn as_stream(&'a mut self) -> Self::Stream;
}

UpdateListener’s supertrait/extension.

This trait is a workaround to not require GAT.

Required Associated Types

type StreamErr

Error that can be returned from the Stream

type Stream: Stream<Item = Result<Update, Self::StreamErr>> + Send + 'a

The stream of updates from Telegram.

Required Methods

fn as_stream(&'a mut self) -> Self::Stream

Creates the update Stream.

Implementors

impl<'a, B: Requester + Send + 'a> AsUpdateStream<'a> for Polling<B>

type StreamErr = <B as Requester>::Err

type Stream = PollingStream<'a, B>

impl<'a, St, Assf, Sf, Hauf, Thf, Strm, E> AsUpdateStream<'a> for StatefulListener<St, Assf, Hauf, Sf, Thf>where
    (St, Strm): 'a,
    Strm: Send + Stream<Item = Result<Update, E>>,
    Assf: FnMut(&'a mut St) -> Strm,

type StreamErr = E

type Stream = Strm