net.sf.asyncobjects.asyncscala.stream
Start building generic aAllFor loop over the stream
Start building generic aAllFor loop over the stream
the body that will be executed as soon as value is available, not waiting for the next value
the aAllFor loop builder
Generic aAllForList loop over the stream
Generic aAllForList loop over the stream
the body that will be executed as soon as value is available, not waiting for the next value
a promise that resolves to list of returned bodies
Generic aAllForUnit loop over the stream
Generic aAllForUnit loop over the stream
the body that will be executed as soon as value is available, not waiting for the next value
a promise that resolves to unit when all bodies completed
The buffered stream that eagerly gets n elements from the underlying stream
and maintain that amount while it is possible.
The buffered stream that eagerly gets n elements from the underlying stream
and maintain that amount while it is possible. The elements are fetched in background.
amount of elements to buffer
the buffered stream
the stream that produces only changed values.
Consume the stream until body returns false or end of stream is reached
Consume the stream until body returns false or end of stream is reached
the body that consumes the stream
the promise that resolves when eof reached
Consume the stream until body returns false or end of stream is reached
Consume the stream until body returns false or end of stream is reached
the body that consumes the stream
the promise that resolves when eof reached
Forward stream to a thunk
Forward stream to a thunk
the destination thunk
a promise that resolves to the number of copied elements
Use this operation if you want to pass the resulting composite stream around.
Use this operation if you want to pass the resulting composite stream around. If you need the transformed stream only for local usage you do not need to export it.
exported stream
Filter stream by type
Filter stream by type
Filter by boolean criteria
Filter stream by predicate
Filter stream by predicate
Filter by boolean criteria
Filter stream by predicate
Filter stream by predicate
Filter by boolean criteria
Filter stream by predicate
Filter stream by predicate
Filter by boolean criteria
stream that allows reading only first n elements, after that none is returned.
Map elements
Map elements
the function that maps element (asynchronously)
mapped stream
Map elements
Map elements
the function that maps element (synchronously)
mapped stream
Left fold the list with immediate function
Left fold the list with immediate function
the initial value for the folding
the the folding function
the rest of the stream converted to list buffer
Left fold the list with immediate function
Left fold the list with immediate function
the initial value for the folding
the the folding function
the rest of the stream converted to list buffer
Generic aSeqFor like loop form
Generic aSeqFor like loop form
the body of the loop
the loop builder
Iterate over the entire stream
Iterate over the entire stream
the iteration body
promise that resolves when iteration finishes
the rest of the stream converted to list
the rest of the stream converted to list buffer
The result stream gets value from underlying stream, then waits for delay
and tries to get a new value, if new value is got, the timer is reset.
The result stream gets value from underlying stream, then waits for delay
and tries to get a new value, if new value is got, the timer is reset. If none
is returned by underlying stream, it is immediately returned. Note that the streams
eagerly reads the values from underlying stream, even when there is no active next request.
So all values except the freshest one are discarded.
a timer service to use
a delay for the value
a stream of values
safely upcasted stream
The stream wrapper. Note that most streams are created here in unexported form. To make reference to the safe use {link #export} operation.