Return AwaitingEventStream from then*For(...).

Author: TomasMikula

reactfx/src/main/java/org/reactfx/EventStream.java

@@ -1102,7 +1102,7 @@ default AwaitingEventStream<T> successionEnds(
      * and these events are emitted, the accumulator value is cleared and any
      * events that arrive within {@code duration} are accumulated, and so on.
      */
-    default <A> EventStream<T> thenAccumulateFor(
+    default <A> AwaitingEventStream<T> thenAccumulateFor(
             Duration duration,
             Function<? super T, ? extends A> initialTransformation,
             BiFunction<? super A, ? super T, ? extends A> reduction,
@@ -1115,7 +1115,7 @@ default <A> EventStream<T> thenAccumulateFor(
                 action -> FxTimer.create(duration, action));
     }
 
-    default <A> EventStream<T> thenAccumulateFor(
+    default <A> AwaitingEventStream<T> thenAccumulateFor(
             Duration duration,
             Function<? super T, ? extends A> initialTransformation,
             BiFunction<? super A, ? super T, ? extends A> reduction,
@@ -1139,7 +1139,7 @@ default <A> EventStream<T> thenAccumulateFor(
      * for cases when it is more convenient to provide a unit element for
      * accumulation than the initial transformation.
      */
-    default <A> EventStream<T> thenAccumulateFor(
+    default <A> AwaitingEventStream<T> thenAccumulateFor(
             Duration duration,
             Supplier<? extends A> unit,
             BiFunction<? super A, ? super T, ? extends A> reduction,
@@ -1153,7 +1153,7 @@ default <A> EventStream<T> thenAccumulateFor(
                 deconstruction);
     }
 
-    default <A> EventStream<T> thenAccumulateFor(
+    default <A> AwaitingEventStream<T> thenAccumulateFor(
             Duration duration,
             Supplier<? extends A> unit,
             BiFunction<? super A, ? super T, ? extends A> reduction,
@@ -1180,7 +1180,7 @@ default <A> EventStream<T> thenAccumulateFor(
      * reduced into a single event, that is emitted after {@code duration} has
      * passed, and so on.
      */
-    default EventStream<T> thenReduceFor(
+    default AwaitingEventStream<T> thenReduceFor(
             Duration duration,
             BinaryOperator<T> reduction) {
         return thenAccumulateFor(
@@ -1190,7 +1190,7 @@ default EventStream<T> thenReduceFor(
                 Collections::singletonList);
     }
 
-    default EventStream<T> thenReduceFor(
+    default AwaitingEventStream<T> thenReduceFor(
             Duration duration,
             BinaryOperator<T> reduction,
             ScheduledExecutorService scheduler,
@@ -1211,11 +1211,11 @@ default EventStream<T> thenReduceFor(
      * duration from the last emitted event. This repeats after each emitted
      * event.
      */
-    default EventStream<T> thenRetainLatestFor(Duration duration) {
+    default AwaitingEventStream<T> thenRetainLatestFor(Duration duration) {
         return thenReduceFor(duration, (a, b) -> b);
     }
 
-    default EventStream<T> thenRetainLatestFor(
+    default AwaitingEventStream<T> thenRetainLatestFor(
             Duration duration,
             ScheduledExecutorService scheduler,
             Executor eventThreadExecutor) {
@@ -1232,15 +1232,15 @@ default EventStream<T> thenRetainLatestFor(
      * The first event that arrives after the given duration is emitted and
      * following events are ignored for the given duration again, and so on.
      */
-    default EventStream<T> thenIgnoreFor(Duration duration) {
+    default AwaitingEventStream<T> thenIgnoreFor(Duration duration) {
         return thenAccumulateFor(
                 duration,
                 t -> Collections.<T>emptyList(),
                 (l, t) -> l,
                 Function.<List<T>>identity());
     }
 
-    default EventStream<T> thenIgnoreFor(
+    default AwaitingEventStream<T> thenIgnoreFor(
             Duration duration,
             ScheduledExecutorService scheduler,
             Executor eventThreadExecutor) {