Add a transformer to this channel.
Add a transformer to this channel.
the transformer
the transformed channel
Poison this channel.
Poison this channel. Any pending read continuation will be invoked with Seg.Nil and NilIChan(signal) as argument.
the signal
Read a segment on this channel.
Read a segment on this channel.
the user-level thread
the continuation invoked if there is a message
The test operation is idempotent meaning that it can be invoked multiple times.
The test operation is idempotent meaning that it can be invoked multiple times.
A test extracts data from its underlying ichan and invokes the ready function on a buffered ichan if a segment is available or on the NilIChan if the underlying ichan is closed.
The contract is the following: - Any channel buffering a non-empty segment is ready - A channel that contains an empty segment followed by a terminated channel is ready - A channel that contains an empty segment followed by a live channel is NOT ready
[use case] Prepend a segment.
Prepend a segment.
an input which produces the segment and which continues with the remaining of the stream.
Prepend a segment.
Prepend a segment.
the segment to prepend.
an input which produces the segment and which continues with the remaining of the stream.
[use case] Prepend a message on this channel.
Prepend a message on this channel.
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 channel.
Prepend a message on this channel.
an input which produces x as first message and
which continues with the remaining of the stream.
[use case] Prepend a message on this channel.
Prepend a message on this channel.
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 channel.
Prepend a message on this channel.
an input which produces x as first message and
which continues with the remaining of the stream.
Operator equivalent to flatMap
Operator equivalent to flatMap
Append a stream after this stream only if this stream terminates normally with EOS.
Append a stream after this stream only if this stream terminates normally with EOS.
the stream to append.
the appended stream.
[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 input channel.
the partial function which filters and maps the stream elements.
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 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 input channel.
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.
Transfer the content of this input to an output.
Transfer the content of this input to an output. The input/output will be closed with the same signal as the output/input.
stream whose result indicates which channel was closed first (Left for ichan, Right for ochan)
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 (defaults to _.toString).
The same input excepted each message will be printed.
Selects all elements except first n ones.
Selects all elements except first n ones.
the number of elements to drop from this stream.
an input consisting of all elements of this input except the first n ones.
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.
[use case] Builds a new input by applying a function to the first message parsed in a stream and the seed of remaining stream.
Builds a new input by applying a function to the first message parsed in a stream and the seed of remaining stream. The new input will then behave like the stream reurned by that function.
the element produced by the parser.
the function.
a new input channel resulting from applying the function f.
Builds a new input by applying a function to the first message parsed in a stream and the seed of remaining stream.
Builds a new input by applying a function to the first message parsed in a stream and the seed of remaining stream. The new input will then behave like the stream reurned by that function.
the element produced by the parser.
the message type of the returned input channel.
the parser used to parse the first message.
the function.
a new input channel resulting from applying the function f.
[use case] Builds a new input by applying a function to the first message in a stream and the seed of remaining stream.
Builds a new input by applying a function to the first message in a stream and the seed of remaining stream. The new input will then behave like the stream returned by that function.
the message type of the returned input channel.
the function.
a new input channel resulting from applying the function f.
Builds a new input by applying a function to the first message in a stream and the seed of remaining stream.
Builds a new input by applying a function to the first message in a stream and the seed of remaining stream. The new input will then behave like the stream returned by that function.
the message type of the returned input channel.
the function.
a new input channel resulting from applying the function f.
[use case] Builds a new collection by applying a function to all messages of this channel and concatenating the results.
Builds a new collection by applying a function to all messages of this channel and concatenating the results.
the message type of the returned collection.
the function to apply to each message.
a new channel resulting from applying the given collection-valued function
f to each message of this channel and concatenating the results.
Builds a new collection by applying a function to all messages of this channel and concatenating the results.
Builds a new collection by applying a function to all messages of this channel and concatenating the results.
the message type of the returned collection.
the function to apply to each message.
a new channel resulting from applying the given collection-valued function
f to each message of this channel 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.
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 conversion which asserts that the message type of this
input channel is a Traversable.
an implicit message definition for the message type of the
Traversable.
a new input resulting from concatenating all the Traversable collections.
Applies a binary operator to a start value and all messages of this channel, going left to right.
Applies a binary operator to a start value and all messages of this channel, going left to right.
the result type of the binary operator.
the start value.
the binary operator.
the result of inserting op between consecutive messages of this channel,
going left to right with the start value z on the left:
op(...op(z, x,,1,,), x,,2,,, ..., x,,n,,)
where x1, ..., xn are the messages of this segment.
Apply sequentially a side effectful function to each message in the stream.
Apply sequentially a side effectful function to each message in the stream.
the effectful function that will be applied to each element of the sequence
stream whose result indicates the termination of the foreach operation.
Forward asynchronously the content of this input to an output.
Forward asynchronously the content of this input to an output. It stops as soon as one of the two channel is poisoned and it does not propagate the poison signal.
A stream that returns the channels after the forward operation. If the stream completed successfully the input channel will be closed, otherwise the output channel is poisoned.
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
Interleave the messages produced asynchronously on this channel with the messages produced on an other channel.
Interleave the messages produced asynchronously on this channel with the messages
produced on an other channel.
This builds a new input channel that produces one message of type Either[A, B] for every
message produce on this or the other channel, where A is the type of messages produced
on this channel and B is the type of messages
produced on the other channel. By default, the resulting channel is closed when both
input channels are closed.
the other input channel
flag that indicating if the resulting channel must be closed if this channel is closed.
flag that indicating if the resulting channel must be closed if the other channel is closed.
a new input channel that produces messages of type Either[A, B] for every message produced on this or the other channel
[use case] Monadic 'join' operator M[M[A]] => M[A].
Monadic 'join' operator M[M[A]] => M[A]. Converts this stream of stream into an stream, which merges messages from all the sub-streams.
the type of the messages of sub-streams.
a new input resulting from merging all the sub-streams.
Monadic 'join' operator M[M[A]] => M[A].
Monadic 'join' operator M[M[A]] => M[A]. Converts this stream of stream into an stream, which merges messages from all the sub-streams.
the type of the messages of sub-streams.
an implicit conversion which asserts that the message type of this
input channel is an IChan.
an implicit message definition for the message type of this stream.
an implicit message definition for the message type of the sub-stream.
a new input resulting from merging all the sub-streams.
Join the messages produced asynchronously on this channel with the messages produced on an other channel.
Join the messages produced asynchronously on this channel with the messages
produced on an other channel.
This builds a new input channel that produces tuples of type (A, B) each time a new message
of type A or B is available, where A is the type of messages produced
on this channel and B is the type of messages
produced on the other channel. The resulting channel is closed both
input channels are closed.
the other input channel
a new input channel that produces messages of type (A, B) for every message produced on this or the other channel
[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.
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.
[use case] Create an input stream by merging all the input streams created by applying the function f
to all the elements of this input stream.
Create an input stream by merging all the input streams created by applying the function f
to all the elements of this input stream.
the type of the messages of input streams created by f.
a function that creates new input streams from each element of this stream.
a new input resulting from merging all the streams created by applying f to
each elements of this stream.
Create an input stream by merging all the input streams created by applying the function f
to all the elements of this input stream.
Create an input stream by merging all the input streams created by applying the function f
to all the elements of this input stream.
the type of the messages of input streams created by f.
a function that creates new input streams from each element of this stream.
an implicit message definition for the message type of this input.
an implicit message definition for the message type of the new streams.
a new input resulting from merging all the streams created by applying f to
each elements of this stream.
[use case] Builds a new input by applying a function that returns a process to all messages of this input.
Builds a new input by applying a function that returns a process 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.
Builds a new input by applying a function that returns a process to all messages of this input.
Builds a new input by applying a function that returns a process 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.
[use case] Builds a new input by applying a function to all segments of this input.
Builds a new input by applying a function to all segments 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 segment of this input.
Builds a new input by applying a function to all segments of this input.
Builds a new input by applying a function to all segments 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 segment of this input.
Merge the streams of two channels.
Merge the streams of two channels.
This builds a new input channel that produces messages from this channel and the other channel.
the other input channel
a new input channel that produces messages coming on both input channels
Append a stream after this stream only if this stream terminates abnormally with a signal that is not EOS.
Append a stream after this stream only if this stream terminates abnormally with a signal that is not EOS.
the stream to append in case of an error signal.
the appended stream.
Append a stream after this stream if this stream terminates with the signal for which the partial function is defined.
Append a stream after this stream if this stream terminates with the signal for which the partial function is defined.
the partial function returning the stream to append if the signal matches the signal(s) for which it is defined.
the appended stream.
Produces an input resulting from applying a repeatedly a parser combinator to this input stream.
Produces an input resulting from applying a repeatedly a parser combinator to this input stream.
the type of the messages parsed
the type of the messages in the resulting input
input with parsed results
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
input with intermediate results
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 input stream is poisoned after the the conforming messages have
been consumed.
the predicate to satisfy
an input producing only of the first messages that satisfy the predicate.
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 predicate to satisfy
a function that takes the remaining of the stream as argument
an input producing only of the first messages that satisfy the predicate.
Read one message on this channel.
Read one message on this channel.
the user-level thread
the continuation invoked if there is a message
the continuation invoked if the channel is closed
Create an input that produces first n messages of this input.
Create an input that produces first n messages of this input. The input stream is poisoned after the n messages have 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.
Create an input that produces first n messages of this input.
Create an input that produces first n messages of this input.
the number of messages to take
a function that takes the remaining of the stream as argument if it is not terminated
an input producing only of the first n messages of this input,
or less than n messages if the input produces less messages.
Create an input that produces messages of this input until an event occurs.
Create an input that produces messages of this input until an event occurs. The input stream is poisoned after the n messages have been consumed.
a channel that delivers the message that will split the current channel.
an input producing messages of this input until the splitter produces and event,
or all the messages if the splitter never delivers an event.
Create an input that produces messages of this input until an event occurs.
Create an input that produces messages of this input until an event occurs.
a channel that delivers the message that will split the current channel
a function that takes the remaining of the stream as argument if it is not terminated.
tailK is invoked with the signal from the splitter if it is terminated.
an input producing messages of this input until the splitter produces and event,
or all the messages if the splitter never delivers an event.
Zip and hence synchronize the streams of two channels.
Zip and hence synchronize the streams of two channels.
This builds a new input channel that produces pair of messages from this channel and the other channel.
the other input channel
a new input channel that produces pairs of messages coming on both input channels
[use case] Zips a stream with its indices.
Zips a stream with its indices.
A new stream containing pairs consisting of all elements of this
stream paired with their index. Indices start at 0.
Zips a stream with its indices.
Zips a stream with its indices.
A new stream containing pairs consisting of all elements of this
stream paired with their index. Indices start at 0.
[use case] Zips a stream with its indices.
Zips a stream with its indices.
A new stream containing pairs consisting of all elements of this
stream paired with their index. Indices start at 0.
Zips a stream with its indices.
Zips a stream with its indices.
A new stream containing pairs consisting of all elements of this
stream paired with their index. Indices start at 0.
IChan that can be tested for the availability of data in memory.