Ignore operator

Rocket.ignore — Function

ignore(count::Int)

Creates a ignore operator, which returns an Observable that skips the first count items emitted by the source Observable.

Arguments

count::Int: the number of times, items emitted by source Observable should be skipped.

Producing

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

Examples

using Rocket

source = from(1:5)

subscribe!(source |> ignore(2), logger())
;

# output

[LogActor] Data: 3
[LogActor] Data: 4
[LogActor] Data: 5
[LogActor] Completed

source

Ignore operator

See also