Index: lib/src/result/capture_transformer.dart |
diff --git a/lib/src/result/capture_transformer.dart b/lib/src/result/capture_transformer.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..ca4d0d39f2480a39cc67fb09bab323782db63775 |
--- /dev/null |
+++ b/lib/src/result/capture_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 'capture_sink.dart'; |
+ |
+/// Use [Result.captureTransformer] instead. |
+@Deprecated("Will be removed in async 2.0.0.") |
Lasse Reichstein Nielsen
2016/03/08 10:40:37
Just @Deprecated("in async 2.0.0")
The Deprecated
nweiz
2016/03/08 20:23:40
I'm mostly concerned with how it appears in dartdo
|
+class CaptureStreamTransformer<T> implements StreamTransformer<T, Result<T>> { |
+ const CaptureStreamTransformer(); |
+ |
+ Stream<Result<T>> bind(Stream<T> source) { |
+ return new Stream<Result<T>>.eventTransformed(source, _createSink); |
+ } |
+ |
+ static EventSink _createSink(EventSink<Result> sink) { |
+ return new CaptureSink(sink); |
+ } |
+} |