SerialSubscription and Timeout operator

Author: johnhmarks

rxjava-core/src/main/java/rx/operators/OperationTimeout.java

@@ -40,6 +40,13 @@ private static class Timeout<T> implements Observable.OnSubscribeFunc<T> {
         private final TimeUnit timeUnit;
         private final Scheduler scheduler;
 
+        private Timeout(Observable<? extends T> source, long timeout, TimeUnit timeUnit, Scheduler scheduler) {
+            this.source = source;
+            this.timeout = timeout;
+            this.timeUnit = timeUnit;
+            this.scheduler = scheduler;
+        }
+
         @Override
         public Subscription onSubscribe(final Observer<? super T> observer) {
             final AtomicBoolean terminated = new AtomicBoolean(false);
@@ -117,12 +124,5 @@ public void onCompleted() {
             serial.setSubscription(schedule.call());
             return composite;
         }
-
-        private Timeout(Observable<? extends T> source, long timeout, TimeUnit timeUnit, Scheduler scheduler) {
-            this.source = source;
-            this.timeout = timeout;
-            this.timeUnit = timeUnit;
-            this.scheduler = scheduler;
-        }
     }
 }