BlockingDoubleChain
Chunked, specialized chain for double values, which supports blocking nextBlocking operation
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Create a copy of current chain state. Consuming resulting chain does not affect initial chain.
Link copied to clipboard
Map the chain result using suspended transformation. Initial chain result can no longer be safely consumed since mapped chain consumes tokens. Accepts regular transformation function.
Link copied to clipboard
inline fun <T, R> Flow<T>.mapParallel(dispatcher: CoroutineDispatcher = Dispatchers.Default, crossinline transform: suspend (T) -> R): Flow<R>
Link copied to clipboard
Get the next value without concurrency support. Not guaranteed to be thread safe.
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Returns an DoubleArray chunk of size values of next.
Link copied to clipboard