Prepend the messages of a given segment in front of this input.
Prepend the messages of a given segment in front of this input.
The segment to prepend.
an input which produces that segment first and then continues with the remaining of the stream.
Prepend a message on this input.
Prepend a message on this input.
the message to prepend.
an input which produces x as first message and
which continues with the remaining of the stream.
Builds a new input by applying a partial function to all messages of this input on which the function is defined.
Builds a new input by applying a partial function to all messages of this input on which the function is defined.
the message type of the returned collection.
the partial function which filters and maps the input.
a new input resulting from applying the partial function
pf to each message on which it is defined.
The order of the messages is preserved.
Builds a new input that compresses the content of each segment into a single value.
Builds a new input that compresses the content of each segment into a single value.
A function converting segments to a single value.
The compressed input.
Builds a new debugging input that prints every message received.
Builds a new debugging input that prints every message received.
the label to put in front of each debug line.
A function converting messages to a string.
The same input excepted each message will be printed.
Skips longest sequence of elements of this input which satisfy given
predicate p, and returns an input of the remaining elements.
Skips longest sequence of elements of this input which satisfy given
predicate p, and returns an input of the remaining elements.
the predicate used to skip elements.
an input producing the remaining elements
Selects all messages of this input which satisfy a predicate.
Selects all messages of this input which satisfy a predicate.
the predicate used to test messages.
a new input consisting of all messages of this input that satisfy the given
predicate p. The order of the messages is preserved.
Builds a new input by applying a function to all messages of this input and concatenating the results.
Builds a new input by applying a function to all messages of this input and concatenating the results.
the message type of the returned input.
the function to apply to each message.
a new input resulting from applying the given collection-valued function
f to each message of this input and concatenating the results.
Converts this input stream of traversable collections into an input stream in which all message collections are concatenated.
Converts this input stream of traversable collections into an input stream in which all message collections are concatenated.
the type of the messages of each traversable collection.
an implicit message definition for the message type of the
Traversable.
an implicit conversion which asserts that the message type of this
input is a Traversable.
a new input resulting from concatenating all the Traversable collections.
Fold left
Forward the content of this input to an output.
Forward the content of this input to an output. It returns when this input is empty but does not close the output.
the output on which to forward this content
the signal that closes this input
Returns an input which groups messages produced by this input into fixed size blocks.
Returns an input which groups messages produced by this input into fixed size blocks. The last group may contain less messages the number of messages receives is not a multiple of the group size.
the size of the groups.
an input producing the groups
Builds a new input by applying a function to all messages of this input.
Builds a new input by applying a function to all messages of this input.
the message type of the returned input.
the function to apply to each message.
a new input resulting from applying the given function
f to each message of this input.
Produces an input resulting from applying a parser combinator to this input stream.
Produces an input resulting from applying a parser combinator to this input stream.
the type of the messages parsed
the type of the messages in the resulting input
a parser combinator
input with parsed results
Poison this input with EOS signal
Poison this input
Poison this input
the poisoning signal
Produces a collection containing cummulative results of applying the operator going first to last message.
Produces a collection containing cummulative results of applying the operator going first to last message.
the type of the messages in the resulting input
the initial value
the binary operator applied to the intermediate result and the message
input with intermediate results
Returns some signal if the input is closed.
Returns some signal if the input is closed.
Some(signal) if the input contain no more elements, None otherwise.
Produces an input containing cummulative results of applying the operator going first to last message.
Produces an input containing cummulative results of applying the operator going first to last message.
the type of the messages in the resulting input
the initial state
input with intermediate results
Create an input that produces longest sequence of this input that satisfy
predicate p.
Create an input that produces longest sequence of this input that satisfy
predicate p. The current input cannot be manipulated until the last value
of the new input has been consumed.
the predicate to satisfy
an input producing only of the first messages that satisfy the predicate.
Create an input that produces first n messages of this input.
Create an input that produces first n messages of this input. The current input cannot be manipulated until the last value of the new input has been consumed.
an input producing only of the first n messages of this input,
or less than n messages if the input produces less messages.
Test the input stream (see stream.
[use case] Prepend the messages of a given segment in front of this input.
Prepend the messages of a given segment in front of this input.
The segment to prepend.
an input which produces that segment first and then continues with the remaining of the stream.
[use case] Prepend a message on this input.
Prepend a message on this input.
the message to prepend.
an input which produces x as first message and
which continues with the remaining of the stream.
[use case] Prepend a message on this input.
Prepend a message on this input.
the message to prepend.
an input which produces x as first message and
which continues with the remaining of the stream.
Prepend a message on this input.
Prepend a message on this input.
the message to prepend.
an input which produces x as first message and
which continues with the remaining of the stream.
Create a selector that reads a value on either input unless one of them is closed.
Create a selector that reads a value on either input unless one of them is closed. If the one of them is closed an SigInput will be raised in the enclosing scope.
Create a selector that reads a value on either input unless the left one is closed.
Create a selector that reads a value on either input unless the left one is closed. If the left input is closed an SigInput will be raised in the enclosing scope.
Create a selector that reads a value on either input unless the right one is closed.
Create a selector that reads a value on either input unless the right one is closed. If the right input is closed an SigInput will be raised in the enclosing scope.
Create a selector that reads a value on either input unless they are both closed.
Create a selector that reads a value on either input unless they are both closed. If both input are closed an SigInput will be raised in the enclosing scope.
[use case] Builds a new input by applying a partial function to all messages of this input on which the function is defined.
Builds a new input by applying a partial function to all messages of this input on which the function is defined.
the message type of the returned collection.
the partial function which filters and maps the input.
a new input resulting from applying the partial function
pf to each message on which it is defined.
The order of the messages is preserved.
[use case] Builds a new input by applying a function to all messages of this input and concatenating the results.
Builds a new input by applying a function to all messages of this input and concatenating the results.
the message type of the returned input.
the function to apply to each message.
a new input resulting from applying the given collection-valued function
f to each message of this input and concatenating the results.
[use case] Converts this input stream of traversable collections into an input stream in which all message collections are concatenated.
Converts this input stream of traversable collections into an input stream in which all message collections are concatenated.
the type of the messages of each traversable collection.
a new input resulting from concatenating all the Traversable collections.
[use case] Applies a function f to all elements of this input.
Applies a function f to all elements of this input.
the function that is applied for its side-effect to every element.
The result of function f is discarded.
Applies a function f to all elements of this input.
Applies a function f to all elements of this input.
the type parameter describing the result of function f.
This result will always be ignored. Typically U is Unit,
but this is not necessary.
the function that is applied for its side-effect to every element.
The result of function f is discarded.
Tests whether this input is closed and returns the signal.
Tests whether this input is closed and returns the signal.
Some(signal) if the input contain no more elements, None otherwise.
Tests whether this input is empty (or closed).
Tests whether this input is empty (or closed).
true if the input contain no more elements, false otherwise.
[use case] Builds a new input by applying a function to all messages of this input.
Builds a new input by applying a function to all messages of this input.
the message type of the returned input.
the function to apply to each message.
a new input resulting from applying the given function
f to each message of this input.
Read a single value or raise the signal if the input is closed
Read a single value or raise the signal if the input is closed
the next element of this input.
Close/poison this input with EOS signal
Close/poison this input with EOS signal
(Since version 3.0) Use poison instead
Close/poison this input
Close/poison this input
the poisoning signal
(Since version 3.0) Use poison instead
Process-level streaming input channel interface.
the type of the input's messages