fail_op

finmqtt_tokio::connection::event_loop::pending

Function fail_op 

pub(super) fn fail_op<T, E: Copy + Into<Error> + StdError + 'static>(
    queued_tx: Option<Sender<Result<(), Error>>>,
    completion_tx: Sender<Result<T, Error>>,
    err: E,
)
Expand description

Resolves an operation’s futures with an error, leaving the connection intact. err is any error source convertible into Error; it is materialised separately for each channel because Error is not Clone.