Contents
-
Deprecated Classes
Please do not use it. It's only used internally.
doesn't work well with futures, promises. And tunneling exception away from the
call stack may cause confusing stack trace that misses the whereabout of the exception.
-
Deprecated Methods
prefer using the concurrently() overloads that allow cancellation
prefer using the concurrently() overloads that allow cancellation
prefer using the concurrently() overloads that allow cancellation
prefer using the concurrently() overloads that allow cancellation
com.google.mu.util.concurrent.Fanout.uninterruptibly(Supplier<A>, Supplier<B>, Supplier<C>, Supplier<D>, Supplier<E>, Fanout.Join5<? super A, ? super B, ? super C, ? super D, ? super E, R, X>)
prefer using the concurrently() overloads that allow cancellation
Use
biStream(User::id, users)
to create
BiStream<UserId, User>
,
or, use
biStream(users, User::getAccount)
to create
BiStream<User, Account>
.
Then use
BiStream.mapKeys(java.util.function.BiFunction<? super K, ? super V, ? extends K2>)
or
BiStream.mapValues(java.util.function.BiFunction<? super K, ? super V, ? extends V2>)
to apply further mappings.
Use
biStream(User::id, users)
to create
BiStream<UserId, User>
,
or, use
biStream(users, User::getAccount)
to create
BiStream<User, Account>
.
Then use
BiStream.mapKeys(java.util.function.BiFunction<? super K, ? super V, ? extends K2>)
or
BiStream.mapValues(java.util.function.BiFunction<? super K, ? super V, ? extends V2>)
to apply further mappings.
Use flatMap()
in Java 10+