pub fn process_await_result<O, M>(observable: O) -> AwaitResult<O, M>where
O: Observable<Message = Result<M>>,
M: Clone + 'static,Expand description
Await a cancellable signal that should be emitted by the specified observable.
pub fn process_await_result<O, M>(observable: O) -> AwaitResult<O, M>where
O: Observable<Message = Result<M>>,
M: Clone + 'static,Await a cancellable signal that should be emitted by the specified observable.