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

Side by Side Diff: lib/src/byte_collector.dart

Issue 2660333005: Change generic comment syntax to real generic syntax. (Closed)
Patch Set: Revert formatting changes. Created 3 years, 10 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
OLDNEW
1 // Copyright (c) 2017, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2017, 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 import "dart:async"; 5 import "dart:async";
6 import "dart:typed_data"; 6 import "dart:typed_data";
7 7
8 /// Collects an asynchronous sequence of byte lists into a single list of bytes. 8 /// Collects an asynchronous sequence of byte lists into a single list of bytes.
9 /// 9 ///
10 /// If the [source] stream emits an error event, 10 /// If the [source] stream emits an error event,
11 /// the collection fails and the returned future completes with the same error. 11 /// the collection fails and the returned future completes with the same error.
12 /// 12 ///
13 /// If any of the input data are not valid bytes, they will be truncated to 13 /// If any of the input data are not valid bytes, they will be truncated to
14 /// an eight-bit unsigned value in the resulting list. 14 /// an eight-bit unsigned value in the resulting list.
15 Future<Uint8List> collectBytes(Stream<List<int>> source) { 15 Future<Uint8List> collectBytes(Stream<List<int>> source) {
16 var byteLists = List<List<int>>[]; 16 var byteLists = <List<int>>[];
17 var length = 0; 17 var length = 0;
18 var completer = new Completer<Uint8List>.sync(); 18 var completer = new Completer<Uint8List>.sync();
19 source.listen( 19 source.listen(
20 (bytes) { 20 (bytes) {
21 byteLists.add(bytes); 21 byteLists.add(bytes);
22 length += bytes.length; 22 length += bytes.length;
23 }, 23 },
24 onError: completer.completeError, 24 onError: completer.completeError,
25 onDone: () { 25 onDone: () {
26 completer.complete(_collect(length, byteLists)); 26 completer.complete(_collect(length, byteLists));
27 }, 27 },
28 cancelOnError: true); 28 cancelOnError: true);
29 return completer.future; 29 return completer.future;
30 } 30 }
31 31
32 // Join a lists of bytes with a known total length into a single [Uint8List]. 32 // Join a lists of bytes with a known total length into a single [Uint8List].
33 Uint8List _collect(int length, List<List<int>> byteLists) { 33 Uint8List _collect(int length, List<List<int>> byteLists) {
34 var result = new Uint8List(length); 34 var result = new Uint8List(length);
35 int i = 0; 35 int i = 0;
36 for (var byteList in byteLists) { 36 for (var byteList in byteLists) {
37 var end = i + byteList.length; 37 var end = i + byteList.length;
38 result.setRange(i, end, byteList); 38 result.setRange(i, end, byteList);
39 i = end; 39 i = end;
40 } 40 }
41 return result; 41 return result;
42 } 42 }
OLDNEW
« CHANGELOG.md ('K') | « CHANGELOG.md ('k') | lib/src/delegate/event_sink.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698