2.x: Replace Action1 with Consumer in docs

Author: akarnokd

src/main/java/io/reactivex/flowables/ConnectableFlowable.java

@@ -111,7 +111,7 @@ public Flowable<T> autoConnect(int numberOfSubscribers) {
      * @param numberOfSubscribers the number of subscribers to await before calling connect
      *                            on the ConnectableObservable. A non-positive value indicates
      *                            an immediate connection.
-     * @param connection the callback Action1 that will receive the Subscription representing the
+     * @param connection the callback Consumer that will receive the Subscription representing the
      *                   established connection
      * @return an Observable that automatically connects to this ConnectableObservable
      *         when the specified number of Subscribers subscribe to it and calls the

src/main/java/io/reactivex/internal/operators/flowable/FlowableRefCount.java

@@ -138,10 +138,10 @@ public void subscribeActual(final Subscriber<? super T> subscriber) {
                 source.connect(onSubscribe(subscriber, writeLocked));
             } finally {
                 // need to cover the case where the source is subscribed to
-                // outside of this class thus preventing the Action1 passed
+                // outside of this class thus preventing the Consumer passed
                 // to source.connect above being called
                 if (writeLocked.get()) {
-                    // Action1 passed to source.connect was not called
+                    // Consumer passed to source.connect was not called
                     lock.unlock();
                 }
             }

src/main/java/io/reactivex/internal/operators/observable/ObservableRefCount.java

@@ -68,10 +68,10 @@ public void subscribeActual(final Observer<? super T> subscriber) {
                 source.connect(onSubscribe(subscriber, writeLocked));
             } finally {
                 // need to cover the case where the source is subscribed to
-                // outside of this class thus preventing the Action1 passed
+                // outside of this class thus preventing the Consumer passed
                 // to source.connect above being called
                 if (writeLocked.get()) {
-                    // Action1 passed to source.connect was not called
+                    // Consumer passed to source.connect was not called
                     lock.unlock();
                 }
             }

src/main/java/io/reactivex/observables/ConnectableObservable.java

@@ -111,7 +111,7 @@ public Observable<T> autoConnect(int numberOfSubscribers) {
      * @param numberOfSubscribers the number of subscribers to await before calling connect
      *                            on the ConnectableObservable. A non-positive value indicates
      *                            an immediate connection.
-     * @param connection the callback Action1 that will receive the Subscription representing the
+     * @param connection the callback Consumer that will receive the Subscription representing the
      *                   established connection
      * @return an Observable that automatically connects to this ConnectableObservable
      *         when the specified number of Subscribers subscribe to it and calls the