Uppercase Operator

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(), logger())
;

# output

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