Represents an infinite stream of data in time, some kind of the cons cell.

An empty stream that never returns data.

Merge two streams applying the FCFS strategy for enqueuing the input data.

Merge two streams.

If you don't know what the strategy to apply, then you probably need the FCFS strategy, or function mergeStreams that does namely this.

Merge two priority streams.

Concatenate the input streams applying the FCFS strategy and producing one output stream.

Concatenate the input streams producing one output stream.

If you don't know what the strategy to apply, then you probably need the FCFS strategy, or function concatStreams that does namely this.

Concatenate the input priority streams producing one output stream.

Split the input stream into the specified number of output streams after applying the FCFS strategy for enqueuing the output requests.

Split the input stream into the specified number of output streams.

If you don't know what the strategy to apply, then you probably need the FCFS strategy, or function splitStream that does namely this.

Split the input stream into a list of output streams using the specified priorities.

Create a stream that will use the specified process identifier. It can be useful to refer to the underlying Process computation which can be passivated, interrupted, canceled and so on. See also the processUsingId function for more details.

Prefetch the input stream requesting for one more data item in advance while the last received item is not yet fully processed in the chain of streams, usually by the processors.

You can think of this as the prefetched stream could place its latest data item in some temporary space for later use, which is very useful for modeling a sequence of separate and independent work places.

Memoize the stream so that it would always return the same data within the simulation run.

Zip two streams trying to get data sequentially.

Zip two streams trying to get data as soon as possible, launching the sub-processes in parallel.

Zip three streams trying to get data sequentially.

Zip three streams trying to get data as soon as possible, launching the sub-processes in parallel.

Unzip the stream.

To form each new portion of data for the output stream, read data sequentially from the input streams.

This is a generalization of zipStreamSeq.

To form each new portion of data for the output stream, read data from the input streams in parallel.

This is a generalization of zipStreamParallel.

Consume the stream. It returns a process that infinitely reads data from the stream and then redirects them to the provided function. It is useful for modeling the process of enqueueing data in the queue from the input stream.

Sink the stream. It returns a process that infinitely reads data from the stream. The resulting computation can be a moving force to simulate the whole system of the interconnected streams and processors.

Return a stream of values generated by the specified process.

Map the stream according the specified function.

Compose the stream.

Transform the stream getting the transformation function after data have come.

Transform the stream getting the transformation function before requesting for data.

Transform the stream trying to get the transformation function as soon as possible at the same time when requesting for the next portion of data.

Filter only those data values that satisfy to the specified predicate.

Filter only those data values that satisfy to the specified predicate.

The stream of Left values.

The stream of Right values.

Replace the Left values.

Replace the Right values.

Partition the stream of Either values into two streams.