Chromium Code Reviews| 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); |
| + } |
| +} |