Path	Lines of Code
analysis_options.yaml	6
lib/async.dart	36
lib/src/async_cache.dart	42
lib/src/async_memoizer.dart	10
lib/src/byte_collector.dart	23
lib/src/cancelable_operation.dart	147
lib/src/chunked_stream_reader.dart	94
lib/src/delegate/event_sink.dart	22
lib/src/delegate/future.dart	22
lib/src/delegate/sink.dart	17
lib/src/delegate/stream.dart	6
lib/src/delegate/stream_consumer.dart	16
lib/src/delegate/stream_sink.dart	24
lib/src/delegate/stream_subscription.dart	38
lib/src/future_group.dart	41
lib/src/lazy_stream.dart	27
lib/src/null_stream_sink.dart	39
lib/src/restartable_timer.dart	20
lib/src/result/capture_sink.dart	18
lib/src/result/capture_transformer.dart	10
lib/src/result/error.dart	41
lib/src/result/future.dart	12
lib/src/result/release_sink.dart	18
lib/src/result/release_transformer.dart	11
lib/src/result/result.dart	94
lib/src/result/value.dart	30
lib/src/single_subscription_transformer.dart	18
lib/src/sink_base.dart	96
lib/src/stream_closer.dart	58
lib/src/stream_completer.dart	69
lib/src/stream_extensions.dart	30
lib/src/stream_group.dart	142
lib/src/stream_queue.dart	423
lib/src/stream_sink_completer.dart	81
lib/src/stream_sink_extensions.dart	8
lib/src/stream_sink_transformer.dart	21
lib/src/stream_sink_transformer/handler_transformer.dart	66
lib/src/stream_sink_transformer/reject_errors.dart	77
lib/src/stream_sink_transformer/stream_transformer_wrapper.dart	38
lib/src/stream_sink_transformer/typed.dart	10
lib/src/stream_splitter.dart	95
lib/src/stream_subscription_transformer.dart	68
lib/src/stream_zip.dart	79
lib/src/subscription_stream.dart	48
lib/src/typed/stream_subscription.dart	33
lib/src/typed_stream_transformer.dart	13
lib/src/utils.dart	3
pubspec.yaml	14