Assist the compiler with type inference.

TomasMikula · Jun 3, 2014 · cabf460 · cabf460
1 parent ade3b67
commit cabf460
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/reactfx/src/main/java/org/reactfx/BiEventSink.java b/reactfx/src/main/java/org/reactfx/BiEventSink.java
@@ -12,6 +12,6 @@ default void push(Tuple2<A, B> t) {
     }
 
     default Subscription feedFrom2(BiEventStream<? extends A, ? extends B> source) {
-        return source.subscribe(this::push);
+        return source.subscribe((a, b) -> push(a, b));
     }
 }
diff --git a/reactfx/src/main/java/org/reactfx/BiEventStream.java b/reactfx/src/main/java/org/reactfx/BiEventStream.java
@@ -25,7 +25,7 @@ default Subscription subscribe(Consumer<? super Tuple2<A, B>> subscriber) {
     }
 
     default Subscription feedTo2(BiEventSink<? super A, ? super B> sink) {
-        return subscribe(sink::push);
+        return subscribe((a, b) -> sink.push(a, b));
     }
 
     default BiEventStream<A, B> hook(

diff --git a/reactfx/src/main/java/org/reactfx/TriEventSink.java b/reactfx/src/main/java/org/reactfx/TriEventSink.java
@@ -12,6 +12,6 @@ default void push(Tuple3<A, B, C> t) {
     }
 
     default Subscription feedFrom3(TriEventStream<? extends A, ? extends B, ? extends C> source) {
-        return source.subscribe(this::push);
+        return source.subscribe((a, b, c) -> push(a, b, c));
     }
 }
diff --git a/reactfx/src/main/java/org/reactfx/TriEventStream.java b/reactfx/src/main/java/org/reactfx/TriEventStream.java
@@ -25,7 +25,7 @@ default Subscription subscribe(Consumer<? super Tuple3<A, B, C>> subscriber) {
     }
 
     default Subscription feedTo3(TriEventSink<? super A, ? super B, ? super C> sink) {
-        return subscribe(sink::push);
+        return subscribe((a, b, c) -> sink.push(a, b, c));
     }
 
     default TriEventStream<A, B, C> hook(