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?