1.0.0 Beta 2
Pre-release
Pre-release
- Pipeline back-pressure has been modified to be relieved immediately when the value is consumed from the pipeline. Prior, another value had to be requested from the pipeline before back-pressure was relieved.
- Removed
AsyncGenerator
class. Instead,fromIterable
now also accepts aClosure
returning aniterable
, which can be a generator function. concurrentOrdered
has been removed andconcurrentUnordered
renamed toconcurrent
. Unfortunately, ordered iteration broke if using operators that would not always emit a value, so support has been dropped.- Added an optional
$bufferSize
parameter to theEmitter
constructor that sets a number of items that can be emitted before awaiting back-pressure from the pipeline consumer. This value defaults to 0, which will await back-pressure with every emitted value.