SkipError Operator

skip_error()

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

Producing

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

Examples

using Rocket

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

# output