async 2.0.6
async: ^2.0.6 copied to clipboard
Utility functions and classes related to the 'dart:async' library.
2.0.6 #
- Add further support for Dart 2.0 library changes to
Stream
.
2.0.5 #
- Fix Dart 2.0 runtime cast errors in
StreamQueue
.
2.0.4 #
-
Add support for Dart 2.0 library changes to
Stream
andStreamTransformer
. Changed classes that implementStreamTransformer
to extendStreamTransformerBase
, and changed signatures offirstWhere
,lastWhere
, andsingleWhere
on classes extendingStream
. See also issue 31847.
2.0.3 #
- Fix a bug in
StreamQueue.startTransaction()
and related methods when rejecting a transaction that isn't the oldest request in the queue.
2.0.2 #
- Add support for Dart 2.0 library changes to class
Timer
.
2.0.1 #
- Fix a fuzzy arrow type warning.
2.0.0 #
-
Remove deprecated public
result.dart
andstream_zip.dart
libraries and deprecated classesReleaseStreamTransformer
andCaptureStreamTransformer
. -
Add
captureAll
andflattenList
static methods toResult
. -
Change
ErrorResult
to not be generic and always be aResult<Null>
. That makes an error independent of the type of result it occurs instead of.
1.13.3 #
- Make
TypeSafeStream
extendStream
instead of implementing it. This ensures that new methods onStream
are automatically picked up, they will go through thelisten
method which type-checks every event.
1.13.2 #
- Fix a type-warning.
1.13.1 #
- Use
FutureOr
for various APIs that had previously useddynamic
.
1.13.0 #
-
Add
collectBytes
andcollectBytesCancelable
functions which collects list-of-byte events into a single byte list. -
Fix a bug where rejecting a
StreamQueueTransaction
would throw aStateError
ifStreamQueue.rest
had been called on one of its child queues. -
StreamQueue.withTransaction()
now properly returns whether or not the transaction was committed.
1.12.0 #
-
Add an
AsyncCache
class that caches asynchronous operations for a period of time. -
Add
StreamQueue.peek
andStreamQueue.lookAheead
. These allow users to look at events without consuming them. -
Add
StreamQueue.startTransaction()
andStreamQueue.withTransaction()
. These allow users to conditionally consume events based on their values. -
Add
StreamQueue.cancelable()
, which allows users to easily make aCancelableOperation
that can be canceled without affecting the queue. -
Add
StreamQueue.eventsDispatched
which counts the number of events that have been dispatched by a given queue. -
Add a
subscriptionTransformer()
function to createStreamTransformer
s that modify the behavior of subscriptions to a stream.
1.11.3 #
- Fix strong-mode warning against the signature of Future.then
1.11.1 #
- Fix new strong-mode warnings introduced in Dart 1.17.0.
1.11.0 #
-
Add a
typedStreamTransformer()
function. This wraps an untypedStreamTransformer
with the correct type parameters, and asserts the types of events as they're emitted from the transformed stream. -
Add a
StreamSinkTransformer.typed()
static method. This wraps an untypedStreamSinkTransformer
with the correct type parameters, and asserts the types of arguments passed in to the resulting sink.
1.10.0 #
-
Add
DelegatingFuture.typed()
,DelegatingStreamSubscription.typed()
,DelegatingStreamConsumer.typed()
,DelegatingSink.typed()
,DelegatingEventSink.typed()
, andDelegatingStreamSink.typed()
static methods. These wrap untyped instances of these classes with the correct type parameter, and assert the types of values as they're accessed. -
Add a
DelegatingStream
class. This is behaviorally identical toStreamView
fromdart:async
, but it follows this package's naming conventions and provides aDelegatingStream.typed()
static method. -
Fix all strong mode warnings and add generic method annotations.
-
new StreamQueue()
,new SubscriptionStream()
,new DelegatingStreamSubscription()
,new DelegatingStreamConsumer()
,new DelegatingSink()
,new DelegatingEventSink()
, andnew DelegatingStreamSink()
now take arguments with generic type arguments (for exampleStream<T>
) rather than without (for exampleStream<dynamic>
). Passing a type that wasn'tis
-compatible with the fully-specified generic would already throw an error under some circumstances, so this is not considered a breaking change. -
ErrorResult
now takes a type parameter. -
Result.asError
now returns aResult<T>
.
1.9.0 #
-
Deprecate top-level libraries other than
package:async/async.dart
, which exports these libraries' interfaces. -
Add
Result.captureStreamTransformer
,Result.releaseStreamTransformer
,Result.captureSinkTransformer
, andResult.releaseSinkTransformer
. -
Deprecate
CaptureStreamTransformer
,ReleaseStreamTransformer
,CaptureSink
, andReleaseSink
.Result.captureStreamTransformer
,Result.releaseStreamTransformer
,Result.captureSinkTransformer
, andResult.releaseSinkTransformer
should be used instead.
1.8.0 #
-
Added
StreamSinkCompleter
, for creating aStreamSink
now and providing its destination later as another sink. -
Added
StreamCompleter.setError
, a shortcut for emitting a single error event on the resulting stream. -
Added
NullStreamSink
, an implementation ofStreamSink
that discards all events.
1.7.0 #
- Added
SingleSubscriptionTransformer
, aStreamTransformer
that converts a broadcast stream into a single-subscription stream.
1.6.0 #
-
Added
CancelableOperation.valueOrCancellation()
, which allows users to be notified when an operation is canceled elsewhere. -
Added
StreamSinkTransformer
which transforms events before they're passed to aStreamSink
, similarly to howStreamTransformer
transforms events after they're emitted by a stream.
1.5.0 #
- Added
LazyStream
, which forwards to the return value of a callback that's only called when the stream is listened to.
1.4.0 #
-
Added
AsyncMemoizer.future
, which allows the result to be accessed beforerunOnce()
is called. -
Added
CancelableOperation
, an asynchronous operation that can be canceled. It can be created using aCancelableCompleter
. -
Added
RestartableTimer
, a non-periodic timer that can be reset over and over.
1.3.0 #
-
Added
StreamCompleter
class for creating a stream now and providing its events later as another stream. -
Added
StreamQueue
class which allows requesting events from a stream before they are avilable. It is like aStreamIterator
that can queue requests. -
Added
SubscriptionStream
which creates a single-subscription stream from an existing stream subscription. -
Added a
ResultFuture
class for synchronously accessing the result of a wrapped future. -
Added
FutureGroup.onIdle
andFutureGroup.isIdle
, which provide visibility into whether a group is actively waiting on any futures. -
Add an
AsyncMemoizer
class for running an asynchronous block of code exactly once. -
Added delegating wrapper classes for a number of core async types:
DelegatingFuture
,DelegatingStreamConsumer
,DelegatingStreamController
,DelegatingSink
,DelegatingEventSink
,DelegatingStreamSink
, andDelegatingStreamSubscription
. These are all simple wrappers that forward all calls to the wrapped objects. They can be used to expose only the desired interface for subclasses, or extended to add extra functionality.
1.2.0 #
-
Added a
FutureGroup
class for waiting for a group of futures, potentially of unknown size, to complete. -
Added a
StreamGroup
class for merging the events of a group of streams, potentially of unknown size. -
Added a
StreamSplitter
class for splitting a stream into multiple new streams.
1.1.1 #
- Updated SDK version constraint to at least 1.9.0.
1.1.0 #
- ChangeLog starts here.