Struct fire_stream_api::client::ReconStrat

pub struct ReconStrat<S> { /* private fields */ }

Reconnection strategy

You should probably add a timeout before reconnecting

Implementations

impl<S> ReconStrat<S>

pub fn new<F>(f: F) -> ReconStrat<S>where
    F: 'static + FnMut(usize) -> PinnedFuture<'static, Result<S, Error>> + Send,

Expects the following fn:

async fn new_stream(error_count: usize) -> io::Result<S>;