Struct ReconnectableStream 

pub struct ReconnectableStream<S, F> { /* private fields */ }

A stream that automatically attempts to reconnect upon encountering an error.

Implementations

impl<S, F, Fut, T, E> ReconnectableStream<S, F>

where S: Stream<Item = Result<T, E>> + Send, F: FnMut() -> Fut + Send, Fut: Future<Output = Result<S, E>> + Send, T: Send, E: Send,

pub fn new(stream: S, reconnect_fn: F, max_retries: usize) -> Self

Creates a new ReconnectableStream.

Trait Implementations

impl<S, F, Fut, T, E> Stream for ReconnectableStream<S, F>

where S: Stream<Item = Result<T, E>> + Send, F: FnMut() -> Fut + Send, Fut: Future<Output = Result<S, E>> + Send, T: Send, E: Send,

type Item = Result<T, E>

The type of items yielded by the stream.

async fn next(&mut self) -> Option<Self::Item>

Attempts to pull out the next value of this stream, returning None if the stream is exhausted.