SkipNext Operator

skip_next()

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

Producing

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

Examples

using Rocket

source = from([ 1, 2, 3 ])
subscribe!(source |> skip_next(), logger())
;

# output
[LogActor] Completed

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