OLD | NEW |
---|---|
(Empty) | |
1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | |
2 // for details. All rights reserved. Use of this source code is governed by a | |
3 // BSD-style license that can be found in the LICENSE file. | |
4 | |
5 import 'dart:async'; | |
6 | |
7 import '../result.dart'; | |
8 import 'capture_sink.dart'; | |
9 | |
10 /// Use [Result.captureTransformer] instead. | |
11 @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
| |
12 class CaptureStreamTransformer<T> implements StreamTransformer<T, Result<T>> { | |
13 const CaptureStreamTransformer(); | |
14 | |
15 Stream<Result<T>> bind(Stream<T> source) { | |
16 return new Stream<Result<T>>.eventTransformed(source, _createSink); | |
17 } | |
18 | |
19 static EventSink _createSink(EventSink<Result> sink) { | |
20 return new CaptureSink(sink); | |
21 } | |
22 } | |
OLD | NEW |