languages/dart-sdk
languages/dart-sdk
1
0
Fork 0
mirror of https://github.com/dart-lang/sdk synced 2024-10-14 17:59:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

[io] Make _HttpDetachedIncoming fields private

Browse source 
Change-Id: If1253a21613f2ea2baa69c68f0999b56e5181322
Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/330703
Reviewed-by: Siva Annamalai <asiva@google.com>
Commit-Queue: Brian Quinlan <bquinlan@google.com>
This commit is contained in:
Brian Quinlan 2023-10-17 18:37:15 +00:00 committed by Commit Queue
parent 339d16e8b1
commit becd3e396c
1 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
sdk/lib/_http/http_parser.dart
View file

@ -176,26 +176,27 @@ class _HttpDetachedStreamSubscription implements StreamSubscription<Uint8List> {
}
class _HttpDetachedIncoming extends Stream<Uint8List> {
final StreamSubscription<Uint8List>? subscription;
final Uint8List? bufferedData;
final StreamSubscription<Uint8List>? _subscription;
final Uint8List? _bufferedData;
_HttpDetachedIncoming(this.subscription, this.bufferedData);
_HttpDetachedIncoming(this._subscription, this._bufferedData);
StreamSubscription<Uint8List> listen(void Function(Uint8List event)? onData,
{Function? onError, void Function()? onDone, bool? cancelOnError}) {
var subscription = this.subscription;
var subscription = this._subscription;
if (subscription != null) {
subscription
..onData(onData)
..onError(onError)
..onDone(onDone);
if (bufferedData == null) {
if (_bufferedData == null) {
return subscription..resume();
}
return _HttpDetachedStreamSubscription(subscription, bufferedData, onData)
return _HttpDetachedStreamSubscription(
subscription, _bufferedData, onData)
..resume();
} else {
return Stream<Uint8List>.fromIterable([bufferedData ?? Uint8List(0)])
return Stream<Uint8List>.fromIterable([_bufferedData ?? Uint8List(0)])
.listen(onData,
onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}