Some Operator
Rocket.some — Functionsome()Creates a some operator, which filters out nothing items by the source Observable by emitting only those that not equal to nothing.
Producing
Stream of type <: Subscribable{L} where L refers to type of source stream <: Subscribable{Union{L, Nothing}}
Examples
using Rocket
source = from([ 1, nothing, 3 ])
subscribe!(source |> some(), logger())
;
# output
[LogActor] Data: 1
[LogActor] Data: 3
[LogActor] Completed
See also: AbstractOperator, InferableOperator, ProxyObservable, max, min, logger
Description
This operator takes values from the source Observable and only emits those values that are not nothing.