Uppercase Operator

Rocket.to_arrayFunction
to_array()

Creates a to_array operator, which reduces all values into a single array and returns this result when the source completes.

Producing

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

Examples

using Rocket

source = from([ 1, 2, 3 ])
subscribe!(source |> to_array(), LoggerActor{Vector{Int}}())
;

# output

[LogActor] Data: [1, 2, 3]
[LogActor] Completed

See also: AbstractOperator, InferableOperator, ProxyObservable, logger

source

See also

Operators, map, lowercase