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 { |