Safe Operator
Rocket.safe — Functionsafe()Creates a SafeOperator, which wraps on_subscribe! and each next!, error! and complete! callbacks into try-catch block.
Producing
Stream of type <: Subscribable{L} where L refers to type of source stream
See also: AbstractOperator, InferableOperator, ProxyObservable, logger