Roll Observatory packages and add a roll script

quiver/lib/src/streams/collect.dart

Index: quiver/lib/src/streams/collect.dart
diff --git a/quiver/lib/src/streams/collect.dart b/quiver/lib/src/streams/collect.dart
deleted file mode 100644
index 0b7719e762b1b97397c09ae61a4185a035798f6c..0000000000000000000000000000000000000000
--- a/quiver/lib/src/streams/collect.dart
+++ /dev/null
@@ -1,37 +0,0 @@
-// Copyright 2014 Google Inc. All Rights Reserved.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//     http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-part of quiver.streams;
-
-/**
- * Returns a stream of completion events for the input [futures].
- *
- * Successfully completed futures yield data events, while futures completed
- * with errors yield error events.
- *
- * The iterator obtained from [futures] is only advanced once the previous
- * future completes and yields an event.  Thus, lazily creating the futures is
- * supported, for example:
- *
- *     collect(files.map((file) => file.readAsString()));
- *
- * If you need to modify [futures], or a backing collection thereof, before the
- * returned stream is done, pass a copy instead to avoid a
- * [ConcurrentModificationError]:
- *
- *     collect(files.toList().map((file) => file.readAsString()));
- *
- */
-Stream collect(Iterable futures) =>
-    new Stream.fromIterable(futures).asyncMap((f) => f);