Drop non-extension methods (dart-lang/stream_transform#88) Prepare to publish as `1.0.0` with only the extension method implementations. All deprecated methods are removed. Temporarily drop build_runner. It was only for the example and doesn't have a constraint allowing a breaking change in this package.
diff --git a/pkgs/stream_transform/CHANGELOG.md b/pkgs/stream_transform/CHANGELOG.md index d9b0049..99d2786 100644 --- a/pkgs/stream_transform/CHANGELOG.md +++ b/pkgs/stream_transform/CHANGELOG.md
@@ -1,3 +1,7 @@ +## 1.0.0 + +- Remove the top level methods and retain the extensions only. + ## 0.0.20 - Add extension methods for most transformers. These should be used in place
diff --git a/pkgs/stream_transform/lib/src/async_map.dart b/pkgs/stream_transform/lib/src/async_map.dart index c9b263f..464e497 100644 --- a/pkgs/stream_transform/lib/src/async_map.dart +++ b/pkgs/stream_transform/lib/src/async_map.dart
@@ -5,7 +5,6 @@ import 'dart:async'; import 'aggregate_sample.dart'; -import 'chain_transformers.dart'; import 'from_handlers.dart'; import 'rate_limit.dart'; @@ -112,62 +111,6 @@ } } -/// Like [Stream.asyncMap] but events are buffered until previous events have -/// been processed by [convert]. -/// -/// If the source stream is a broadcast stream the result will be as well. When -/// used with a broadcast stream behavior also differs from [Stream.asyncMap] in -/// that the [convert] function is only called once per event, rather than once -/// per listener per event. -/// -/// The first event from the source stream is always passed to [convert] as a -/// List with a single element. After that events are buffered until the -/// previous Future returned from [convert] has fired. -/// -/// Errors from the source stream are forwarded directly to the result stream. -/// Errors during the conversion are also forwarded to the result stream and are -/// considered completing work so the next values are let through. -/// -/// The result stream will not close until the source stream closes and all -/// pending conversions have finished. -@Deprecated('Use the extension instead') -StreamTransformer<S, T> asyncMapBuffer<S, T>( - Future<T> Function(List<S>) convert) { - var workFinished = StreamController<void>() - // Let the first event through. - ..add(null); - return chainTransformers( - buffer(workFinished.stream), _asyncMapThen(convert, workFinished.add)); -} - -/// Like [Stream.asyncMap] but events are discarded while work is happening in -/// [convert]. -/// -/// If the source stream is a broadcast stream the result will be as well. When -/// used with a broadcast stream behavior also differs from [Stream.asyncMap] in -/// that the [convert] function is only called once per event, rather than once -/// per listener per event. -/// -/// If no work is happening when an event is emitted it will be immediately -/// passed to [convert]. If there is ongoing work when an event is emitted it -/// will be held until the work is finished. New events emitted will replace a -/// pending event. -/// -/// Errors from the source stream are forwarded directly to the result stream. -/// Errors during the conversion are also forwarded to the result stream and are -/// considered completing work so the next values are let through. -/// -/// The result stream will not close until the source stream closes and all -/// pending conversions have finished. -@Deprecated('Use the extension instead') -StreamTransformer<S, T> asyncMapSample<S, T>(Future<T> Function(S) convert) { - var workFinished = StreamController<void>() - // Let the first event through. - ..add(null); - return chainTransformers(AggregateSample(workFinished.stream, _dropPrevious), - _asyncMapThen(convert, workFinished.add)); -} - T _dropPrevious<T>(T event, _) => event; /// Like [Stream.asyncMap] but the [convert] is only called once per event, @@ -187,41 +130,3 @@ } }); } - -/// Like [Stream.asyncMap] but the [convert] callback may be called for an -/// element before processing for the previous element is finished. -/// -/// Events on the result stream will be emitted in the order that [convert] -/// completed which may not match the order of the original stream. -/// -/// If the source stream is a broadcast stream the result will be as well. When -/// used with a broadcast stream behavior also differs from [Stream.asyncMap] in -/// that the [convert] function is only called once per event, rather than once -/// per listener per event. The [convert] callback won't be called for events -/// while a broadcast stream has no listener. -/// -/// Errors from the source stream are forwarded directly to the result stream. -/// Errors during the conversion are also forwarded to the result stream. -/// -/// The result stream will not close until the source stream closes and all -/// pending conversions have finished. -@Deprecated('Use the extension instead') -StreamTransformer<S, T> concurrentAsyncMap<S, T>(FutureOr<T> convert(S event)) { - var valuesWaiting = 0; - var sourceDone = false; - return fromHandlers(handleData: (element, sink) { - valuesWaiting++; - () async { - try { - sink.add(await convert(element)); - } catch (e, st) { - sink.addError(e, st); - } - valuesWaiting--; - if (valuesWaiting <= 0 && sourceDone) sink.close(); - }(); - }, handleDone: (sink) { - sourceDone = true; - if (valuesWaiting <= 0) sink.close(); - }); -}
diff --git a/pkgs/stream_transform/lib/src/chain_transformers.dart b/pkgs/stream_transform/lib/src/chain_transformers.dart deleted file mode 100644 index 1e812d9..0000000 --- a/pkgs/stream_transform/lib/src/chain_transformers.dart +++ /dev/null
@@ -1,24 +0,0 @@ -// Copyright (c) 2018, the Dart project authors. Please see the AUTHORS file -// for details. All rights reserved. Use of this source code is governed by a -// BSD-style license that can be found in the LICENSE file. - -import 'dart:async'; - -/// Combines two transformers into one. -/// -/// This is most useful to keep a reference to the combination and use it in -/// multiple places or give it a descriptive name. For inline uses the directly -/// chained calls to `.transform` should be preferred. -/// -/// For example: -/// -/// ``` -/// /// values.transform(splitDecoded) is identical to -/// /// values.transform(utf8.decoder).transform(const LineSplitter()) -/// final splitDecoded = chainTransformers(utf8.decoder, const LineSplitter()); -/// ``` -@Deprecated('This utility should not be needed with extension methods') -StreamTransformer<S, T> chainTransformers<S, I, T>( - StreamTransformer<S, I> first, StreamTransformer<I, T> second) => - StreamTransformer.fromBind( - (values) => values.transform(first).transform(second));
diff --git a/pkgs/stream_transform/lib/src/combine_latest.dart b/pkgs/stream_transform/lib/src/combine_latest.dart index 4e35997..bacc7d6 100644 --- a/pkgs/stream_transform/lib/src/combine_latest.dart +++ b/pkgs/stream_transform/lib/src/combine_latest.dart
@@ -76,38 +76,6 @@ transform(_CombineLatestAll<T>(others)); } -/// Combine the latest value from the source stream with the latest value from -/// [other] using [combine]. -/// -/// No event will be emitted from the result stream until both the source stream -/// and [other] have each emitted at least one event. Once both streams have -/// emitted at least one event, the result stream will emit any time either -/// input stream emits. -/// -/// For example: -/// source.transform(combineLatest(other, (a, b) => a + b)); -/// -/// source: -/// 1--2-----4 -/// other: -/// ------3--- -/// result: -/// ------5--7 -/// -/// The result stream will not close until both the source stream and [other] -/// have closed. -/// -/// Errors thrown by [combine], along with any errors on the source stream or -/// [other], are forwarded to the result stream. -/// -/// If the source stream is a broadcast stream, the result stream will be as -/// well, regardless of [other]'s type. If a single subscription stream is -/// combined with a broadcast stream it may never be canceled. -@Deprecated('Use the extension instead') -StreamTransformer<S, R> combineLatest<S, T, R>( - Stream<T> other, FutureOr<R> Function(S, T) combine) => - _CombineLatest(other, combine); - class _CombineLatest<S, T, R> extends StreamTransformerBase<S, R> { final Stream<T> _other; final FutureOr<R> Function(S, T) _combine; @@ -218,45 +186,6 @@ } } -/// Combine the latest value emitted from the source stream with the latest -/// values emitted from [others]. -/// -/// [combineLatestAll] subscribes to the source stream and [others] and when -/// any one of the streams emits, the result stream will emit a [List<T>] of -/// the latest values emitted from all streams. -/// -/// The result stream will not emit until all source streams emit at least -/// once. If a source stream emits multiple values before another starts -/// emitting, all but the last value will be lost. -/// -/// The result stream will not close until all source streams have closed. When -/// a source stream closes, the result stream will continue to emit the last -/// value from the closed stream when the other source streams emit until the -/// result stream has closed. If a source stream closes without emitting any -/// value, the result stream will close as well. -/// -/// Errors thrown by any source stream will be forwarded to the result stream. -/// -/// If the source stream is a broadcast stream, the result stream will be as -/// well, regardless of the types of [others]. If a single subscription stream -/// is combined with a broadcast source stream, it may never be canceled. -/// -/// ## Example -/// -/// (Suppose first, second, and third are Stream<String>) -/// final combined = first -/// .transform(combineLatestAll([second, third])) -/// .map((data) => data.join()); -/// -/// first: a----b------------------c--------d---| -/// second: --1---------2-----------------| -/// third: -------&----------%---| -/// combined: -------b1&--b2&---b2%---c2%------d2%-| -/// -@Deprecated('Use the extension instead') -StreamTransformer<T, List<T>> combineLatestAll<T>(Iterable<Stream<T>> others) => - _CombineLatestAll<T>(others); - class _CombineLatestAll<T> extends StreamTransformerBase<T, List<T>> { final Iterable<Stream<T>> _others;
diff --git a/pkgs/stream_transform/lib/src/concatenate.dart b/pkgs/stream_transform/lib/src/concatenate.dart index 402a4bc..f9ba747 100644 --- a/pkgs/stream_transform/lib/src/concatenate.dart +++ b/pkgs/stream_transform/lib/src/concatenate.dart
@@ -53,21 +53,6 @@ } } -/// Starts emitting values from [next] after the original stream is complete. -/// -/// If the initial stream never finishes, the [next] stream will never be -/// listened to. -/// -/// If a single-subscription follows the a broadcast stream it may be listened -/// to and never canceled. -/// -/// If a broadcast stream follows any other stream it will miss any events which -/// occur before the first stream is done. If a broadcast stream follows a -/// single-subscription stream, pausing the stream while it is listening to the -/// second stream will cause events to be dropped rather than buffered. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> followedBy<T>(Stream<T> next) => _FollowedBy<T>(next); - class _FollowedBy<T> extends StreamTransformerBase<T, T> { final Stream<T> _next; @@ -134,36 +119,3 @@ return controller.stream; } } - -/// Emits [initial] before any values from the original stream. -/// -/// If the original stream is a broadcast stream the result will be as well. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> startWith<T>(T initial) => - startWithStream<T>(Future.value(initial).asStream()); - -/// Emits all values in [initial] before any values from the original stream. -/// -/// If the original stream is a broadcast stream the result will be as well. If -/// the original stream is a broadcast stream it will miss any events which -/// occur before the initial values are all emitted. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> startWithMany<T>(Iterable<T> initial) => - startWithStream<T>(Stream.fromIterable(initial)); - -/// Emits all values in [initial] before any values from the original stream. -/// -/// If the original stream is a broadcast stream the result will be as well. If -/// the original stream is a broadcast stream it will miss any events which -/// occur before [initial] closes. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> startWithStream<T>(Stream<T> initial) => - StreamTransformer.fromBind((values) { - if (values.isBroadcast && !initial.isBroadcast) { - initial = initial.asBroadcastStream(); - } - return initial.transform(followedBy(values)); - }); - -@Deprecated('Use followedBy instead') -StreamTransformer<T, T> concat<T>(Stream<T> next) => followedBy<T>(next);
diff --git a/pkgs/stream_transform/lib/src/map.dart b/pkgs/stream_transform/lib/src/map.dart deleted file mode 100644 index e1f7137..0000000 --- a/pkgs/stream_transform/lib/src/map.dart +++ /dev/null
@@ -1,21 +0,0 @@ -// Copyright (c) 2018, the Dart project authors. Please see the AUTHORS file -// for details. All rights reserved. Use of this source code is governed by a -// BSD-style license that can be found in the LICENSE file. - -import 'dart:async'; - -/// Models a [Stream.map] callback as a [StreamTransformer]. -/// -/// This is most useful to pass to functions that take a [StreamTransformer] -/// other than [Stream.transform]. For inline uses [Stream.map] should be -/// preferred. -/// -/// For example: -/// -/// ``` -/// final sinkMapper = new StreamSinkTransformer.fromStreamTransformer( -/// map((v) => '$v')); -/// ``` -@Deprecated('This utility should not be needed with extension methods') -StreamTransformer<S, T> map<S, T>(T convert(S event)) => - StreamTransformer.fromBind((stream) => stream.map(convert));
diff --git a/pkgs/stream_transform/lib/src/merge.dart b/pkgs/stream_transform/lib/src/merge.dart index 736cde5..bbcf759 100644 --- a/pkgs/stream_transform/lib/src/merge.dart +++ b/pkgs/stream_transform/lib/src/merge.dart
@@ -56,25 +56,6 @@ Stream<T> mergeAll(Iterable<Stream<T>> others) => transform(_Merge(others)); } -/// Emits values from the source stream and [other] in any order as they arrive. -/// -/// If the source stream is a broadcast stream, the result stream will be as -/// well, regardless of [other]'s type. If a single subscription stream is -/// merged into a broadcast stream it may never be canceled. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> merge<T>(Stream<T> other) => _Merge<T>([other]); - -/// Emits values from the source stream and all streams in [others] in any order -/// as they arrive. -/// -/// If the source stream is a broadcast stream, the result stream will be as -/// well, regardless of the types of streams in [others]. If single -/// subscription streams are merged into a broadcast stream they may never be -/// canceled. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> mergeAll<T>(Iterable<Stream<T>> others) => - _Merge<T>(others); - class _Merge<T> extends StreamTransformerBase<T, T> { final Iterable<Stream<T>> _others;
diff --git a/pkgs/stream_transform/lib/src/rate_limit.dart b/pkgs/stream_transform/lib/src/rate_limit.dart index 91a7648..db6d7df 100644 --- a/pkgs/stream_transform/lib/src/rate_limit.dart +++ b/pkgs/stream_transform/lib/src/rate_limit.dart
@@ -135,25 +135,6 @@ transform(AggregateSample<T, List<T>>(trigger, _collect)); } -/// Creates a StreamTransformer which only emits when the source stream does not -/// emit for [duration]. -/// -/// Source values will always be delayed by at least [duration], and values -/// which come within this time will replace the old values, only the most -/// recent value will be emitted. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> debounce<T>(Duration duration) => - _debounceAggregate(duration, _dropPrevious); - -/// Creates a StreamTransformer which collects values until the source stream -/// does not emit for [duration] then emits the collected values. -/// -/// This differs from [debounce] in that values are aggregated instead of -/// skipped. -@Deprecated('Use the extension instead') -StreamTransformer<T, List<T>> debounceBuffer<T>(Duration duration) => - _debounceAggregate(duration, _collectToList); - List<T> _collectToList<T>(T element, List<T> soFar) { soFar ??= <T>[]; soFar.add(element); @@ -189,68 +170,4 @@ }); } -/// Creates a StreamTransformer which only emits once per [duration], at the -/// beginning of the period. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> throttle<T>(Duration duration) { - Timer timer; - - return fromHandlers(handleData: (data, sink) { - if (timer == null) { - sink.add(data); - timer = Timer(duration, () { - timer = null; - }); - } - }); -} - -/// Creates a StreamTransformer which only emits once per [duration], at the -/// end of the period. -/// -/// Always introduces a delay of at most [duration]. -/// -/// Differs from `throttle` in that it always emits the most recently received -/// event rather than the first in the period. -/// -/// Differs from `debounce` in that a value will always be emitted after -/// [duration], the output will not be starved by values coming in repeatedly -/// within [duration]. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> audit<T>(Duration duration) { - Timer timer; - var shouldClose = false; - T recentData; - - return fromHandlers(handleData: (T data, EventSink<T> sink) { - recentData = data; - timer ??= Timer(duration, () { - sink.add(recentData); - timer = null; - if (shouldClose) { - sink.close(); - } - }); - }, handleDone: (EventSink<T> sink) { - if (timer != null) { - shouldClose = true; - } else { - sink.close(); - } - }); -} - -/// Creates a [StreamTransformer] which collects values and emits when it sees a -/// value on [trigger]. -/// -/// If there are no pending values when [trigger] emits, the next value on the -/// source Stream will immediately flow through. Otherwise, the pending values -/// are released when [trigger] emits. -/// -/// Errors from the source stream or the trigger are immediately forwarded to -/// the output. -@Deprecated('Use the extension instead') -StreamTransformer<T, List<T>> buffer<T>(Stream<void> trigger) => - AggregateSample<T, List<T>>(trigger, _collect); - List<T> _collect<T>(T event, List<T> soFar) => (soFar ?? <T>[])..add(event);
diff --git a/pkgs/stream_transform/lib/src/scan.dart b/pkgs/stream_transform/lib/src/scan.dart index bd2073f..b31b9e7 100644 --- a/pkgs/stream_transform/lib/src/scan.dart +++ b/pkgs/stream_transform/lib/src/scan.dart
@@ -26,25 +26,3 @@ }); } } - -/// Scan is like fold, but instead of producing a single value it yields -/// each intermediate accumulation. -/// -/// If [combine] returns a Future it will not be called again for subsequent -/// events from the source until it completes, therefor the combine callback is -/// always called for elements in order, and the result stream always maintains -/// the same order as the original. -@Deprecated('Use the extension instead') -StreamTransformer<S, T> scan<S, T>( - T initialValue, FutureOr<T> combine(T previousValue, S element)) => - StreamTransformer.fromBind((source) { - var accumulated = initialValue; - return source.asyncMap((value) { - var result = combine(accumulated, value); - if (result is Future<T>) { - return result.then((r) => accumulated = r); - } else { - return accumulated = result as T; - } - }); - });
diff --git a/pkgs/stream_transform/lib/src/switch.dart b/pkgs/stream_transform/lib/src/switch.dart index eb58cc5..2e2aeba 100644 --- a/pkgs/stream_transform/lib/src/switch.dart +++ b/pkgs/stream_transform/lib/src/switch.dart
@@ -32,29 +32,6 @@ Stream<T> switchLatest() => transform(_SwitchTransformer<T>()); } -/// Maps events to a Stream and emits values from the most recently created -/// Stream. -/// -/// When the source emits a value it will be converted to a [Stream] using -/// [convert] and the output will switch to emitting events from that result. -/// -/// If the source stream is a broadcast stream, the result stream will be as -/// well, regardless of the types of the streams produced by [convert]. -@Deprecated('Use the extension instead') -StreamTransformer<S, T> switchMap<S, T>(Stream<T> convert(S event)) => - StreamTransformer.fromBind( - (source) => source.map(convert).transform(switchLatest())); - -/// Emits values from the most recently emitted Stream. -/// -/// When the source emits a stream the output will switch to emitting events -/// from that stream. -/// -/// If the source stream is a broadcast stream, the result stream will be as -/// well, regardless of the types of streams emitted. -@Deprecated('Use the extension instead') -StreamTransformer<Stream<T>, T> switchLatest<T>() => _SwitchTransformer<T>(); - class _SwitchTransformer<T> extends StreamTransformerBase<Stream<T>, T> { const _SwitchTransformer();
diff --git a/pkgs/stream_transform/lib/src/take_until.dart b/pkgs/stream_transform/lib/src/take_until.dart index 862222e..43b35d1 100644 --- a/pkgs/stream_transform/lib/src/take_until.dart +++ b/pkgs/stream_transform/lib/src/take_until.dart
@@ -16,16 +16,6 @@ Stream<T> takeUntil(Future<void> trigger) => transform(_TakeUntil(trigger)); } -/// Emits values from the stream until [trigger] fires. -/// -/// Completing [trigger] differs from canceling a subscription in that values -/// which are emitted before the trigger, but have further asynchronous delays -/// in transformations following the takeUtil, will still go through. Cancelling -/// a subscription immediately stops values. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> takeUntil<T>(Future<void> trigger) => - _TakeUntil(trigger); - class _TakeUntil<T> extends StreamTransformerBase<T, T> { final Future<void> _trigger;
diff --git a/pkgs/stream_transform/lib/src/tap.dart b/pkgs/stream_transform/lib/src/tap.dart index 5d8198f..1942b12 100644 --- a/pkgs/stream_transform/lib/src/tap.dart +++ b/pkgs/stream_transform/lib/src/tap.dart
@@ -44,40 +44,3 @@ sink.close(); })); } - -/// Taps into a Stream to allow additional handling on a single-subscriber -/// stream without first wrapping as a broadcast stream. -/// -/// The [onValue] callback will be called with every value from the original -/// stream before it is forwarded to listeners on the resulting stream. May be -/// null if only [onError] or [onDone] callbacks are needed. -/// -/// The [onError] callback will be called with every error from the original -/// stream before it is forwarded to listeners on the resulting stream. -/// -/// The [onDone] callback will be called after the original stream closes and -/// before the resulting stream is closed. -/// -/// Errors from any of the callbacks are ignored. -/// -/// The callbacks may not be called until the tapped stream has a listener, and -/// may not be called after the listener has canceled the subscription. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> tap<T>(void Function(T) onValue, - {void Function(Object, StackTrace) onError, void Function() onDone}) => - fromHandlers(handleData: (value, sink) { - try { - onValue?.call(value); - } catch (_) {/*Ignore*/} - sink.add(value); - }, handleError: (error, stackTrace, sink) { - try { - onError?.call(error, stackTrace); - } catch (_) {/*Ignore*/} - sink.addError(error, stackTrace); - }, handleDone: (sink) { - try { - onDone?.call(); - } catch (_) {/*Ignore*/} - sink.close(); - });
diff --git a/pkgs/stream_transform/lib/src/where.dart b/pkgs/stream_transform/lib/src/where.dart index 33c0f7e..7026923 100644 --- a/pkgs/stream_transform/lib/src/where.dart +++ b/pkgs/stream_transform/lib/src/where.dart
@@ -55,24 +55,6 @@ } } -/// Emits only the events which have type [R]. -/// -/// If the source stream is a broadcast stream the result will be as well. -/// -/// Errors from the source stream are forwarded directly to the result stream. -/// -/// The static type of the returned transformer takes `Null` so that it can -/// satisfy the subtype requirements for the `stream.transform()` argument on -/// any source stream. The argument to `bind` has been broadened to take -/// `Stream<Object>` since it will never be passed a `Stream<Null>` at runtime. -/// This is safe to use on any source stream. -/// -/// [R] should be a subtype of the stream's generic type, otherwise nothing of -/// type [R] could possibly be emitted, however there is no static or runtime -/// checking that this is the case. -@Deprecated('Use the extension instead') -StreamTransformer<Null, R> whereType<R>() => _WhereType<R>(); - class _WhereType<R> extends StreamTransformerBase<Null, R> { @override Stream<R> bind(Stream<Object> source) { @@ -105,39 +87,3 @@ return controller.stream; } } - -/// Like [Stream.where] but allows the [test] to return a [Future]. -/// -/// Events on the result stream will be emitted in the order that [test] -/// completes which may not match the order of the original stream. -/// -/// If the source stream is a broadcast stream the result will be as well. When -/// used with a broadcast stream behavior also differs from [Stream.where] in -/// that the [test] function is only called once per event, rather than once -/// per listener per event. -/// -/// Errors from the source stream are forwarded directly to the result stream. -/// Errors during the conversion are also forwarded to the result stream. -/// -/// The result stream will not close until the source stream closes and all -/// pending [test] calls have finished. -@Deprecated('Use the extension instead') -StreamTransformer<T, T> asyncWhere<T>(FutureOr<bool> test(T element)) { - var valuesWaiting = 0; - var sourceDone = false; - return fromHandlers(handleData: (element, sink) { - valuesWaiting++; - () async { - try { - if (await test(element)) sink.add(element); - } catch (e, st) { - sink.addError(e, st); - } - valuesWaiting--; - if (valuesWaiting <= 0 && sourceDone) sink.close(); - }(); - }, handleDone: (sink) { - sourceDone = true; - if (valuesWaiting <= 0) sink.close(); - }); -}
diff --git a/pkgs/stream_transform/lib/stream_transform.dart b/pkgs/stream_transform/lib/stream_transform.dart index 2f7bf24..d04c4dd 100644 --- a/pkgs/stream_transform/lib/stream_transform.dart +++ b/pkgs/stream_transform/lib/stream_transform.dart
@@ -3,10 +3,8 @@ // BSD-style license that can be found in the LICENSE file. export 'src/async_map.dart'; -export 'src/chain_transformers.dart'; export 'src/combine_latest.dart'; export 'src/concatenate.dart'; -export 'src/map.dart'; export 'src/merge.dart'; export 'src/rate_limit.dart'; export 'src/scan.dart';
diff --git a/pkgs/stream_transform/pubspec.yaml b/pkgs/stream_transform/pubspec.yaml index 8528f21..5442357 100644 --- a/pkgs/stream_transform/pubspec.yaml +++ b/pkgs/stream_transform/pubspec.yaml
@@ -2,7 +2,7 @@ description: A collection of utilities to transform and manipulate streams. author: Dart Team <misc@dartlang.org> homepage: https://www.github.com/dart-lang/stream_transform -version: 0.0.20 +version: 1.0.0 environment: sdk: ">=2.6.0 <3.0.0" @@ -10,6 +10,3 @@ dev_dependencies: pedantic: ^1.5.0 test: ^1.0.0 - # Example - build_runner: ^1.0.0 - build_web_compilers: ^2.0.0