Skip to main content

Stream

CHANGED​

changed(Stream s) -> Stream
STABLE

Stream containing the elements of stream s that are different 

 than their predecessor

changed(Stream of Vector s, Vector of Number indexes) -> Stream of Vector
STABLE

Stream containing the vectors of stream s whose elements in indexes 

 are different than their predecessor

CONCAT​

concat(Stream a, Stream b) -> Stream
STABLE

Add stream b after stream a

DEBOUNCE​

debounce(Stream s, Number start_s, Number debounce) -> Stream
STABLE

Skip elements in s arriving in the first start_s seconds and stop 

 when `s` has not emitted any new values in the last `debounce`
 seconds

DIOTA​

diota(Real pace, Integer l, Integer u) -> Stream of Integer
STABLE

Stream of natural numbers between l and u 

 with delays of `pace` seconds between produced stream elements

EXTRACT​

extract(Stream s) -> Bag
STABLE

Extract elements in stream s one by one as elements in a bag

FIRST​

first(Stream s) -> Object
STABLE

The first element in stream s

FIRST_N​

first_n(Stream s, Number n) -> Stream
STABLE

The stream of the first n elements in stream s

HEARTBEAT​

heartbeat(Real pace) -> Stream of Real
STABLE

Stream of seconds from start emitted at given pace in seconds

HEARTBEAT_WRAP​

heartbeat_wrap(Stream s, Number pace) -> Stream
STABLE

No description.

heartbeat_wrap(Bag b, Number pace) -> Stream
STABLE

Convert bag b into stream with sampling frequency pace

HISTOGRAM​

histogram(Stream s, Vector limits) -> Stream of Vector of Integer
STABLE

Calculate a stream of histograms over stream s, with limits vector.

limits is a vector with [min,max,number of bins] the range for the histograms is always $ [min,max) $

histogram(Stream of Number s, Number min, Number max, Number bins) -> Stream of Vector of Integer
STABLE

No description.

histogram(Stream of Vector s, Vector of Vector limits) -> Stream of Vector of Vector
STABLE

No description.

IN​

in(Stream s) -> Bag
STABLE

No description.

MERGE​

merge(Stream s1, Stream s2) -> Stream
STABLE

Merge streams s1 and s2

merge(Vector of Stream vs) -> Stream
STABLE

Merge streams in vs

PIVOT​

pivot(Vector of Stream vs, Vector iv) -> Stream of Vector
STABLE

A stream of the most recently received values in vs, 

 having the vector `iv` as the initial element

pivot(Vector of Stream vs) -> Stream of Vector
STABLE

A stream of the most recently received elements in vs

PIVOT_EVENTS​

pivot_events(Vector keys, Stream of Vector bus) -> Stream of Timeval of Vector
STABLE

No description.

pivot_events(Vector keys, Vector initial_values, Stream of Vector s) -> Stream of Timeval of Vector
STABLE

No description.

PIVOT_STREAMS​

pivot_streams(Vector of Stream vs, Vector iv) -> Stream of Vector
DEPRECATED

No description.

This was deprecated in version 4.15.5.

Use pivot(vs,iv) instead

pivot_streams(Vector of Stream vs) -> Stream of Vector
DEPRECATED

No description.

This was deprecated in version 4.15.5.

Use pivot(vs)

PLAYBACK​

playback(Stream s) -> Stream
STABLE

Playback time stamped stream of vectors s with pace 

 according to time stamp in each first vector elements of `s`

PRED_MERGE​

pred_merge(Vector of Stream vs, Number timeout_slack, Function selector, Vector selector_args) -> Stream
STABLE

No description.

pred_merge(Vector of Stream vs, Number timeout_slack, Function selector) -> Stream
STABLE

Advanced merge operator. Operator will wait for timeout_slack for each stream in vs

to push a value. The operator maintains internally a vector v of the last elements seen in the vector of stream vs. The operator calls selector(Vector v)->Integer index for each incoming value in the vector of stream vs. The selector function should return the index of the vector v to replace next. The operator then also emits the selected element.

PRED_PIVOT​

pred_pivot(Vector of Stream vs, Number timeout_slack, Function selector, Vector selector_args) -> Stream of Vector
STABLE

No description.

pred_pivot(Vector of Stream vs, Number timeout_slack, Function selector) -> Stream of Vector
STABLE

No description.

RANDSTREAM​

randstream(Real l, Real u) -> Stream of Real
STABLE

Infinite stream of random numbers between l and u

RAVG​

ravg(Stream s) -> Stream of Real
STABLE

Running averages of elements in stream s

RCOUNT​

rcount(Stream s) -> Stream of Integer
STABLE

Stream of running count of elements in stream s

READLINES​

readlines(Charstring file, Charstring delim, Number chunk) -> Stream of Vector of Charstring
STABLE

No description.

readlines(Charstring file) -> Stream of Charstring
STABLE

Stream of lines in file

READ_FILE_CHUNKED​

read_file_chunked(Charstring file, Integer chunk) -> Stream
STABLE

No description.

REMOTE:FUNCTION​

remote:function(Charstring peer, Charstring fn, Vector args) -> Stream
STABLE

No description.

REMOTE:QUERY​

remote:query(Charstring peer, Charstring query) -> Stream
STABLE

No description.

REMOTE_FUNCTION_STREAM​

remote_function_stream(Charstring peer, Charstring fn, Vector args) -> Stream of Vector
STABLE

No description.

RSUM​

rsum(Stream s) -> Stream of Real
STABLE

Stream of running averages of elements in stream s

SAMPLE_EVERY​

sample_every(Stream s, Real pace) -> Stream
STABLE

Run stream s and emit values every pace seconds since the last value

SAMPLE_STREAM​

sample_stream(Bag expression, Real pace) -> Stream
STABLE

Stream of expression evaluated every pace seconds

SAVE_LAST_ELEMENT​

save_last_element(Stream s, Function f) -> Stream
STABLE

No description.

SECTION​

section(Stream s, Number start, Number stop) -> Stream
STABLE

The section of stream s starting at position start 

 and ending at `stop`.

SIMSIG​

simsig(Real x) -> Real
STABLE

A simulated harmonic stream reading x seconds from its start

SIMSTREAM​

simstream(Real pace) -> Stream of Real
STABLE

A simulated harmonic stream

SINK​

sink(Stream s)
STABLE

Run stream s silently without extracting any elements

SIOTA​

siota(Integer l, Integer u) -> Stream of Integer
STABLE

Stream of natural numbers between l and u

SKIP​

skip(Stream s, Number n) -> Stream
STABLE

Skip first n elements in stream s

SKIP_S​

skip_s(Stream s, Number sec) -> Stream
STABLE

Skip all elements arriving in the first sec seconds of 

 stream `s`.

STREAMOF​

streamof(Bag b) -> Stream
STABLE

Convert a bag b to a stream

streamof(Stream s) -> Stream
STABLE

No description.

STREAM_FUNCTION_TUPLES​

stream_function_tuples(Charstring peer, Charstring fn, Vector args) -> Bag of Vector
STABLE

No description.

TIMEOUT​

timeout(Stream s, Number timeout) -> Stream
STABLE

No description.

TIMESTAMPS​

timestamps(Number pace) -> Stream of Charstring
STABLE

Stream of local timestamp UTC every pace seconds

TIMESTREAM​

timestream(Number pace) -> Stream of Timeval
STABLE

Stream of time stamps every pace seconds

TIME_SECTION​

time_section(Stream s, Number start_s, Number stop_s) -> Stream
STABLE

Skip elements in s arriving in the first start_s seconds and stop 

 after `stop_s` seconds. This is similar to `section(stream,start,stop)`, 
 except that the start and stop values are real-time seconds.

TIME_SPENT​

time_spent(Stream s) -> Real
STABLE

Real time spent in running s

TS_SIMSTREAM​

ts_simstream(Real pace) -> Stream of Timeval of Real
STABLE

A sumulated time stamped harmonic stream

VECTOROF​

vectorof(Stream b) -> Vector v
STABLE

Convert finite stream to vector

VSTREAM​

vstream(Vector v) -> Stream
STABLE

Convert a vector v to a stream

WRITELINES​

writelines(Stream s, Charstring file) -> Charstring
STABLE

Create file by lines in stream s

ZIP​

zip(Vector of Stream vs, Vector of Integer indices) -> Stream of Vector
STABLE

A stream where each received vector in vs is "zipped" together on the

ices. Vector elements not in indices` will retain the latest seen value

zip(Vector of Stream vs) -> Stream of Vector
STABLE

A stream where each received values in vs is "zipped" together one at a

. Should only be used of streams have the same pace.