Skip to content

Commit c20b00f

Browse files
committed
Convert from fj.data.Stream to java.util.stream.Stream
1 parent 675e465 commit c20b00f

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

java8/src/main/java/fj/data/Java8.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,13 @@
66
import fj.function.Try2;
77

88
import java.util.Optional;
9+
import java.util.Spliterator;
10+
import java.util.Spliterators;
911
import java.util.function.BiFunction;
1012
import java.util.function.Consumer;
1113
import java.util.function.Function;
1214
import java.util.function.Supplier;
15+
import java.util.stream.StreamSupport;
1316

1417
/**
1518
* Created by mperry on 3/06/2014.
@@ -119,5 +122,13 @@ public static <A> F<A, Unit> Consumer_F(Consumer<A> c) {
119122
};
120123
}
121124

125+
static public <A> java.util.stream.Stream<A> Stream_JStream(fj.data.Stream<A> s) {
126+
Spliterator<A> sit = Spliterators.spliteratorUnknownSize(s.iterator(), 0);
127+
return StreamSupport.stream(sit, false);
128+
}
129+
130+
static public <A> F<fj.data.Stream<A>, java.util.stream.Stream<A>> Stream_JStream() {
131+
return s -> Stream_JStream(s);
132+
}
122133

123134
}

0 commit comments

Comments
 (0)