Index: lib/src/result/release_transformer.dart |
diff --git a/lib/src/result/release_transformer.dart b/lib/src/result/release_transformer.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..456ed0a90d11c5232835809baa406a352c8b8ca7 |
--- /dev/null |
+++ b/lib/src/result/release_transformer.dart |
@@ -0,0 +1,22 @@ |
+// Copyright (c) 2016, 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'; |
+ |
+import '../result.dart'; |
+import 'release_sink.dart'; |
+ |
+/// Use [Result.releaseTransformer] instead. |
+@Deprecated("Will be removed in async 2.0.0.") |
+class ReleaseStreamTransformer<T> implements StreamTransformer<Result<T>, T> { |
+ const ReleaseStreamTransformer(); |
+ |
+ Stream<T> bind(Stream<Result<T>> source) { |
+ return new Stream<T>.eventTransformed(source, _createSink); |
+ } |
+ |
+ static EventSink<Result> _createSink(EventSink sink) { |
+ return new ReleaseSink(sink); |
+ } |
+} |