Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(82)

Unified Diff: packages/quiver/lib/src/async/concat.dart

Issue 2989763002: Update charted to 0.4.8 and roll (Closed)
Patch Set: Removed Cutch from list of reviewers Created 3 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « packages/quiver/lib/src/async/collect.dart ('k') | packages/quiver/lib/src/async/countdown_timer.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 {
« no previous file with comments | « packages/quiver/lib/src/async/collect.dart ('k') | packages/quiver/lib/src/async/countdown_timer.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698