You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
zip(Supplier<A>):UberStream<Tuple2<T,A>>
and optionally:
zip(Stream<A>):UberStream<Tuple2<T,A>>
All methods should zip each element of the current stream with next elements from the specified iterable, or supplier, or stream. Number of elements in the current stream is the limit of elements taken from specified entity. If specified entity doesn't have enough elements - exception should be raised.
Note: type of the result stream should be Tuple2 instead of UberMaps.Entry, since Tuple2 implements entry, but is more specific and perfectly suitable for this usecase. Exisitng zip(Function) may be refactored to also return Tuple2.
Note:zip(Stream) should be implemented only if it will NOT perform immediate termination of any of the used streams (current, or specified). So this method should perform kind of a "stream union" that will be actually performed only when terminating operation is performed on the result stream.
The text was updated successfully, but these errors were encountered:
UserStream
should provider methods:zip(Iterable<A>):UberStream<Tuple2<T,A>>
zip(Supplier<A>):UberStream<Tuple2<T,A>>
and optionally:
zip(Stream<A>):UberStream<Tuple2<T,A>>
All methods should zip each element of the current stream with next elements from the specified iterable, or supplier, or stream. Number of elements in the current stream is the limit of elements taken from specified entity. If specified entity doesn't have enough elements - exception should be raised.
Note: type of the result stream should be
Tuple2
instead ofUberMaps.Entry
, sinceTuple2
implements entry, but is more specific and perfectly suitable for this usecase. Exisitngzip(Function)
may be refactored to also returnTuple2
.Note:
zip(Stream)
should be implemented only if it will NOT perform immediate termination of any of the used streams (current, or specified). So this method should perform kind of a "stream union" that will be actually performed only when terminating operation is performed on the result stream.The text was updated successfully, but these errors were encountered: