SkipError Operator

skip_error()

Creates a skip_error operator, which filters out the error event from the source Observable, emitting only next and complete messages.

Producing

Stream of type <: Subscribable{L} where L refers to the type of the source stream

Examples

using Rocket

source = faulted("error")
subscribe!(source |> skip_error(), logger())
;

# output

See also: AbstractOperator, InferableOperator, ProxyObservable, skip_error, skip_complete, logger