Update PR based on feedback

  - Deprecate ignoreElements
  - Update docs for TimerInterval and TimeStamped
  - Update docs for flatMap

Author: brianegan

lib/src/transformers/flat_map.dart

@@ -113,8 +113,7 @@ extension FlatMapExtension<T> on Stream<T> {
   /// ### Example
   ///
   ///     RangeStream(4, 1)
-  ///       .flatMap((i) =>
-  ///         TimerStream(i, Duration(minutes: i))
+  ///       .flatMap((i) => TimerStream(i, Duration(minutes: i))
   ///       .listen(print); // prints 1, 2, 3, 4
   Stream<S> flatMap<S>(Stream<S> mapper(T value)) =>
       transform(FlatMapStreamTransformer<T, S>(mapper));
@@ -129,8 +128,7 @@ extension FlatMapExtension<T> on Stream<T> {
   /// ### Example
   ///
   ///     RangeStream(1, 4)
-  ///       .flatMapIterable((i) =>
-  ///         Stream.fromIterable([[]i])
+  ///       .flatMapIterable((i) => Stream.fromIterable([[i]])
   ///       .listen(print); // prints 1, 2, 3, 4
   Stream<S> flatMapIterable<S>(Stream<Iterable<S>> mapper(T value)) =>
       transform(FlatMapStreamTransformer<T, Iterable<S>>(mapper))

lib/src/transformers/ignore_elements.dart

@@ -10,6 +10,7 @@ import 'dart:async';
 ///       ErrorStream(Exception())
 ///     ])
 ///     .listen(print, onError: print); // prints Exception
+@Deprecated('Use the drain method from the Stream class instead')
 class IgnoreElementsStreamTransformer<T> extends StreamTransformerBase<T, T> {
   final StreamTransformer<T, T> _transformer;
 
@@ -55,5 +56,6 @@ extension IgnoreElementsExtension<T> on Stream<T> {
   ///      Stream.error(Exception())
   ///    ])
   ///    .listen(print, onError: print); // prints Exception
+  @Deprecated('Use the drain method from the Stream class instead')
   Stream<T> ignoreElements() => transform(IgnoreElementsStreamTransformer<T>());
 }

lib/src/transformers/time_interval.dart

@@ -98,9 +98,8 @@ class TimeInterval<T> {
   }
 }
 
-/// Extends the Stream class with the ability to wrap each item emitted by the
-/// source Stream in a [Timestamped] object that includes the emitted item
-/// and the time when the item was emitted.
+/// Extends the Stream class with the ability to record the time interval
+/// between consecutive values in an stream
 extension TimeIntervalExtension<T> on Stream<T> {
   /// Records the time interval between consecutive values in a Stream sequence.
   ///

lib/src/transformers/timestamp.dart

@@ -79,7 +79,9 @@ class Timestamped<T> {
   }
 }
 
-/// Extends the Stream class with the ability to
+/// Extends the Stream class with the ability to wrap each item emitted by the
+/// source Stream in a [Timestamped] object that includes the emitted item and
+/// the time when the item was emitted.
 extension TimeStampExtension<T> on Stream<T> {
   /// Wraps each item emitted by the source Stream in a [Timestamped] object
   /// that includes the emitted item and the time when the item was emitted.

test/transformers/ignore_elements_test.dart

@@ -21,6 +21,7 @@ void main() {
   test('Rx.ignoreElements', () async {
     var hasReceivedEvent = false;
 
+    // ignore: deprecated_member_use_from_same_package
     _getStream().ignoreElements().listen((_) {
       hasReceivedEvent = true;
     },
@@ -30,6 +31,7 @@ void main() {
   });
 
   test('Rx.ignoreElements.reusable', () async {
+    // ignore: deprecated_member_use_from_same_package
     final transformer = IgnoreElementsStreamTransformer<int>();
     var hasReceivedEvent = false;
 
@@ -49,6 +51,7 @@ void main() {
   });
 
   test('Rx.ignoreElements.asBroadcastStream', () async {
+    // ignore: deprecated_member_use_from_same_package
     final stream = _getStream().asBroadcastStream().ignoreElements();
 
     // listen twice on same stream
@@ -61,6 +64,7 @@ void main() {
   test('Rx.ignoreElements.pause.resume', () async {
     var hasReceivedEvent = false;
 
+    // ignore: deprecated_member_use_from_same_package
     _getStream().ignoreElements().listen((_) {
       hasReceivedEvent = true;
     },
@@ -72,6 +76,7 @@ void main() {
   });
 
   test('Rx.ignoreElements.error.shouldThrow', () async {
+    // ignore: deprecated_member_use_from_same_package
     final streamWithError = Stream<void>.error(Exception()).ignoreElements();
 
     streamWithError.listen(null,