Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(230)

Side by Side Diff: sdk/lib/io/data_transformer.dart

Issue 12610006: Renamed StreamSink to EventSink. Renamed signalError to addError. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Changed inheritance back! Now create StreamSink instead of EventSink where we create them. Created 7 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 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. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 part of dart.io; 5 part of dart.io;
6 6
7 /** 7 /**
8 * Private helper-class to handle native filters. 8 * Private helper-class to handle native filters.
9 */ 9 */
10 abstract class _Filter { 10 abstract class _Filter {
(...skipping 21 matching lines...) Expand all
32 external static _Filter newZLibInflateFilter(); 32 external static _Filter newZLibInflateFilter();
33 } 33 }
34 34
35 35
36 class _FilterTransformer extends StreamEventTransformer<List<int>, List<int>> { 36 class _FilterTransformer extends StreamEventTransformer<List<int>, List<int>> {
37 final _Filter _filter; 37 final _Filter _filter;
38 bool _closed = false; 38 bool _closed = false;
39 39
40 _FilterTransformer(_Filter this._filter); 40 _FilterTransformer(_Filter this._filter);
41 41
42 void handleData(List<int> data, StreamSink<List<int>> sink) { 42 void handleData(List<int> data, EventSink<List<int>> sink) {
43 if (_closed) return; 43 if (_closed) return;
44 try { 44 try {
45 _filter.process(data); 45 _filter.process(data);
46 var out; 46 var out;
47 while ((out = _filter.processed(flush: false)) != null) { 47 while ((out = _filter.processed(flush: false)) != null) {
48 sink.add(out); 48 sink.add(out);
49 } 49 }
50 } catch (e, s) { 50 } catch (e, s) {
51 _closed = true; 51 _closed = true;
52 sink.signalError(new AsyncError(e, s)); 52 sink.addError(new AsyncError(e, s));
53 sink.close(); 53 sink.close();
54 } 54 }
55 } 55 }
56 56
57 void handleDone(StreamSink<List<int>> sink) { 57 void handleDone(EventSink<List<int>> sink) {
58 if (_closed) return; 58 if (_closed) return;
59 try { 59 try {
60 var out; 60 var out;
61 while ((out = _filter.processed()) != null) { 61 while ((out = _filter.processed()) != null) {
62 sink.add(out); 62 sink.add(out);
63 } 63 }
64 } catch (e, s) { 64 } catch (e, s) {
65 sink.signalError(new AsyncError(e, s)); 65 sink.addError(new AsyncError(e, s));
66 _closed = true; 66 _closed = true;
67 } 67 }
68 if (!_closed) _filter.end(); 68 if (!_closed) _filter.end();
69 sink.close(); 69 sink.close();
70 } 70 }
71 } 71 }
72 72
73 73
74 /** 74 /**
75 * ZLibDeflater class used to deflate a stream of bytes, using zlib. 75 * ZLibDeflater class used to deflate a stream of bytes, using zlib.
76 */ 76 */
77 class ZLibDeflater extends _FilterTransformer { 77 class ZLibDeflater extends _FilterTransformer {
78 ZLibDeflater({bool gzip: true, int level: 6}) 78 ZLibDeflater({bool gzip: true, int level: 6})
79 : super(_Filter.newZLibDeflateFilter(gzip, level)); 79 : super(_Filter.newZLibDeflateFilter(gzip, level));
80 } 80 }
81 81
82 82
83 /** 83 /**
84 * ZLibInflater class used to inflate a stream of bytes, using zlib. 84 * ZLibInflater class used to inflate a stream of bytes, using zlib.
85 */ 85 */
86 class ZLibInflater extends _FilterTransformer { 86 class ZLibInflater extends _FilterTransformer {
87 ZLibInflater() : super(_Filter.newZLibInflateFilter()); 87 ZLibInflater() : super(_Filter.newZLibInflateFilter());
88 } 88 }
89 89
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698