locke
02/12/2019, 6:09 PMObservable<T> into an Observable<Message<T>> or something similar, where the messages were the onSubscribe, onNext, onComplete, and onError events with the T as the payload, does anyone remember what that operator is named?