diff --git a/src/main/java/cyclops/stream/FutureStream.java b/src/main/java/cyclops/stream/FutureStream.java index c33c422aba..c6b47eaa71 100644 --- a/src/main/java/cyclops/stream/FutureStream.java +++ b/src/main/java/cyclops/stream/FutureStream.java @@ -965,8 +965,8 @@ default FutureStream parallel(Function,? extends Stream } @Override - default FutureStream jooλ(Function, ? extends Seq> mapper){ - return fromStream(ReactiveSeq.super.jooλ(mapper)); + default FutureStream jool(Function, ? extends Seq> mapper){ + return fromStream(ReactiveSeq.super.jool(mapper)); } @Override diff --git a/src/main/java/cyclops/stream/ReactiveSeq.java b/src/main/java/cyclops/stream/ReactiveSeq.java index c97cc22725..1262347ced 100644 --- a/src/main/java/cyclops/stream/ReactiveSeq.java +++ b/src/main/java/cyclops/stream/ReactiveSeq.java @@ -78,7 +78,7 @@ * A powerful extended, sequential Stream type. * Extends JDK 8 java.util.reactiveStream.Stream. * Implements the reactive-reactiveStream publisher api. - * Replayable Stream by default, using primitive operators (ints,longs, doubles or jooλ results in conversion toNested a oneshot Stream + * Replayable Stream by default, using primitive operators (ints,longs, doubles or jool results in conversion toNested a oneshot Stream * (as of 2.0.0-MI1) * * Features include diff --git a/src/main/java/cyclops/stream/Streamable.java b/src/main/java/cyclops/stream/Streamable.java index 8f373910dc..f7736037f3 100644 --- a/src/main/java/cyclops/stream/Streamable.java +++ b/src/main/java/cyclops/stream/Streamable.java @@ -2437,7 +2437,7 @@ default Streamable> innerJoin(final Streamable other, final * @see org.jooq.lambda.Seq#leftOuterJoin(java.util.reactiveStream.Stream, java.util.function.BiPredicate) */ default Streamable> leftOuterJoin(final Streamable other, final BiPredicate predicate) { - return fromStream(reactiveSeq().jooλ(s->s.leftOuterJoin(other, predicate))); + return fromStream(reactiveSeq().jool(s->s.leftOuterJoin(other, predicate))); } @@ -2445,7 +2445,7 @@ default Streamable> leftOuterJoin(final Streamable other, fi * @see org.jooq.lambda.Seq#rightOuterJoin(java.util.reactiveStream.Stream, java.util.function.BiPredicate) */ default Streamable> rightOuterJoin(final Streamable other, final BiPredicate predicate) { - return fromStream(reactiveSeq().jooλ(s->s.rightOuterJoin(other, predicate))); + return fromStream(reactiveSeq().jool(s->s.rightOuterJoin(other, predicate))); } /** If this Streamable is empty replace it with a another Stream