| Index: lib/src/result.dart
|
| diff --git a/lib/src/result.dart b/lib/src/result.dart
|
| deleted file mode 100644
|
| index 49457c35fa113edd7d2ecc629ea5e360b14e9ab4..0000000000000000000000000000000000000000
|
| --- a/lib/src/result.dart
|
| +++ /dev/null
|
| @@ -1,150 +0,0 @@
|
| -// 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/capture_transformer.dart';
|
| -import 'result/error.dart';
|
| -import 'result/release_transformer.dart';
|
| -import 'result/value.dart';
|
| -import 'stream_sink_transformer.dart';
|
| -
|
| -/// The result of a computation.
|
| -///
|
| -/// Capturing a result (either a returned value or a thrown error) means
|
| -/// converting it into a [Result] - either a [ValueResult] or an [ErrorResult].
|
| -///
|
| -/// This value can release itself by writing itself either to a [EventSink] or a
|
| -/// [Completer], or by becoming a [Future].
|
| -abstract class Result<T> {
|
| - /// A stream transformer that captures a stream of events into [Result]s.
|
| - ///
|
| - /// The result of the transformation is a stream of [Result] values and no
|
| - /// error events. This is the transformer used by [captureStream].
|
| - static const StreamTransformer<Object, Result> captureStreamTransformer =
|
| - const CaptureStreamTransformer();
|
| -
|
| - /// A stream transformer that releases a stream of result events.
|
| - ///
|
| - /// The result of the transformation is a stream of values and error events.
|
| - /// This is the transformer used by [releaseStream].
|
| - static const StreamTransformer<Object, Result> releaseStreamTransformer =
|
| - const ReleaseStreamTransformer();
|
| -
|
| - /// A sink transformer that captures events into [Result]s.
|
| - ///
|
| - /// The result of the transformation is a sink that only forwards [Result]
|
| - /// values and no error events.
|
| - static const StreamSinkTransformer<Object, Result> captureSinkTransformer =
|
| - const StreamSinkTransformer.fromStreamTransformer(
|
| - const CaptureStreamTransformer());
|
| -
|
| - /// A sink transformer that releases result events.
|
| - ///
|
| - /// The result of the transformation is a sink that forwards of values and
|
| - /// error events.
|
| - static const StreamSinkTransformer<Object, Result> releaseSinkTransformer =
|
| - const StreamSinkTransformer.fromStreamTransformer(
|
| - const ReleaseStreamTransformer());
|
| -
|
| - /// Create a `Result` with the result of calling [computation].
|
| - ///
|
| - /// This generates either a [ValueResult] with the value returned by
|
| - /// calling `computation`, or an [ErrorResult] with an error thrown by
|
| - /// the call.
|
| - factory Result(T computation()) {
|
| - try {
|
| - return new ValueResult(computation());
|
| - } catch (e, s) {
|
| - return new ErrorResult(e, s);
|
| - }
|
| - }
|
| -
|
| - /// Create a `Result` holding a value.
|
| - ///
|
| - /// Alias for [ValueResult.ValueResult].
|
| - factory Result.value(T value) = ValueResult<T>;
|
| -
|
| - /// Create a `Result` holding an error.
|
| - ///
|
| - /// Alias for [ErrorResult.ErrorResult].
|
| - factory Result.error(Object error, [StackTrace stackTrace]) =>
|
| - new ErrorResult(error, stackTrace);
|
| -
|
| - /// Capture the result of a future into a `Result` future.
|
| - ///
|
| - /// The resulting future will never have an error.
|
| - /// Errors have been converted to an [ErrorResult] value.
|
| - static Future<Result<T>> capture<T>(Future<T> future) {
|
| - return future.then((value) => new ValueResult(value),
|
| - onError: (error, stackTrace) => new ErrorResult<T>(error, stackTrace));
|
| - }
|
| -
|
| - /// Release the result of a captured future.
|
| - ///
|
| - /// Converts the [Result] value of the given [future] to a value or error
|
| - /// completion of the returned future.
|
| - ///
|
| - /// If [future] completes with an error, the returned future completes with
|
| - /// the same error.
|
| - static Future<T> release<T>(Future<Result<T>> future) =>
|
| - future.then<T>((result) => result.asFuture);
|
| -
|
| - /// Capture the results of a stream into a stream of [Result] values.
|
| - ///
|
| - /// The returned stream will not have any error events.
|
| - /// Errors from the source stream have been converted to [ErrorResult]s.
|
| - static Stream<Result<T>> captureStream<T>(Stream<T> source) =>
|
| - source.transform(new CaptureStreamTransformer<T>());
|
| -
|
| - /// Release a stream of [result] values into a stream of the results.
|
| - ///
|
| - /// `Result` values of the source stream become value or error events in
|
| - /// the returned stream as appropriate.
|
| - /// Errors from the source stream become errors in the returned stream.
|
| - static Stream<T> releaseStream<T>(Stream<Result<T>> source) =>
|
| - source.transform(new ReleaseStreamTransformer<T>());
|
| -
|
| - /// Converts a result of a result to a single result.
|
| - ///
|
| - /// If the result is an error, or it is a `Result` value
|
| - /// which is then an error, then a result with that error is returned.
|
| - /// Otherwise both levels of results are value results, and a single
|
| - /// result with the value is returned.
|
| - static Result<T> flatten<T>(Result<Result<T>> result) {
|
| - if (result.isValue) return result.asValue.value;
|
| - return new ErrorResult<T>(result.asError.error, result.asError.stackTrace);
|
| - }
|
| -
|
| - /// Whether this result is a value result.
|
| - ///
|
| - /// Always the opposite of [isError].
|
| - bool get isValue;
|
| -
|
| - /// Whether this result is an error result.
|
| - ///
|
| - /// Always the opposite of [isValue].
|
| - bool get isError;
|
| -
|
| - /// If this is a value result, return itself.
|
| - ///
|
| - /// Otherwise return `null`.
|
| - ValueResult<T> get asValue;
|
| -
|
| - /// If this is an error result, return itself.
|
| - ///
|
| - /// Otherwise return `null`.
|
| - ErrorResult<T> get asError;
|
| -
|
| - /// Complete a completer with this result.
|
| - void complete(Completer<T> completer);
|
| -
|
| - /// Add this result to an [EventSink].
|
| - ///
|
| - /// Calls the sink's `add` or `addError` method as appropriate.
|
| - void addTo(EventSink<T> sink);
|
| -
|
| - /// Creates a future completed with this result as a value or an error.
|
| - Future<T> get asFuture;
|
| -}
|
|
|