pub fn process_await<O>(observable: O) -> Await<O, O::Message>where O: Observable, O::Message: Clone + 'static,
Await a signal that should be emitted by the specified observable.