| Index: packages/quiver/lib/src/async/concat.dart
|
| diff --git a/packages/quiver/lib/src/streams/concat.dart b/packages/quiver/lib/src/async/concat.dart
|
| similarity index 70%
|
| rename from packages/quiver/lib/src/streams/concat.dart
|
| rename to packages/quiver/lib/src/async/concat.dart
|
| index d8c44e05bce8b97c1f0d02eef7b5fa656f585d6d..e83ed6476412f4ab63a5a69e476cfbe8b177f0c7 100644
|
| --- a/packages/quiver/lib/src/streams/concat.dart
|
| +++ b/packages/quiver/lib/src/async/concat.dart
|
| @@ -12,29 +12,26 @@
|
| // See the License for the specific language governing permissions and
|
| // limitations under the License.
|
|
|
| -part of quiver.streams;
|
| +part of quiver.async;
|
|
|
| -/**
|
| - * Returns the concatentation of the input streams.
|
| - *
|
| - * When the returned stream is listened to, the [streams] are iterated through
|
| - * asynchronously, forwarding all events (both data and error) for the current
|
| - * stream to the returned stream before advancing the iterator and listening to
|
| - * the next stream. If advancing the iterator throws an error, the returned
|
| - * stream ends immediately with that error.
|
| - *
|
| - * Pausing and resuming the returned stream's subscriptions will pause and
|
| - * resume the subscription of the current stream being listened to.
|
| - *
|
| - * Note: Events from pre-existing broadcast streams which occur before
|
| - * the stream is reached by the iteration will be dropped.
|
| - *
|
| - * Example:
|
| - *
|
| - * concat(files.map((file) =>
|
| - * file.openRead().transform(const LineSplitter())))
|
| - *
|
| - */
|
| +/// Returns the concatentation of the input streams.
|
| +///
|
| +/// When the returned stream is listened to, the [streams] are iterated through
|
| +/// asynchronously, forwarding all events (both data and error) for the current
|
| +/// stream to the returned stream before advancing the iterator and listening
|
| +/// to the next stream. If advancing the iterator throws an error, the
|
| +/// returned stream ends immediately with that error.
|
| +///
|
| +/// Pausing and resuming the returned stream's subscriptions will pause and
|
| +/// resume the subscription of the current stream being listened to.
|
| +///
|
| +/// Note: Events from pre-existing broadcast streams which occur before the
|
| +/// stream is reached by the iteration will be dropped.
|
| +///
|
| +/// Example:
|
| +///
|
| +/// concat(files.map((file) =>
|
| +/// file.openRead().transform(const LineSplitter())))
|
| Stream concat(Iterable<Stream> streams) => new _ConcatStream(streams);
|
|
|
| class _ConcatStream extends Stream {
|
|
|