blob: bf6dd505abd52d947717dfd2d02b2a19442647a4 [file] [log] [blame]
// Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
import 'dart:async';
import 'result.dart';
/// Used by [Result.releaseSink].
class ReleaseSink<T> implements EventSink<Result<T>> {
final EventSink<T> _sink;
ReleaseSink(this._sink);
@override
void add(Result<T> result) {
result.addTo(_sink);
}
@override
void addError(Object error, [StackTrace? stackTrace]) {
// Errors may be added by intermediate processing, even if it is never
// added by CaptureSink.
_sink.addError(error, stackTrace);
}
@override
void close() {
_sink.close();
}
}