default <R>SimpleReactStream<R> anyOf(final Function<? super U,? extends R> fn){
  final CompletableFuture[] array=lastActiveArray(getLastActive());
  final CompletableFuture cf=CompletableFuture.anyOf(array);
  final CompletableFuture onSuccess=cf.thenApplyAsync(fn,getTaskExecutor());
  return (SimpleReactStream<R>)withLastActive(new EagerStreamWrapper(onSuccess,getErrorHandler()));
}

default < R > SimpleReactStream < R > anyOf ( final Function < ? super U , ? extends R > fn ) { final CompletableFuture [ ] array = lastActiveArray ( getLastActive ( ) ) ; final CompletableFuture cf = CompletableFuture . anyOf ( array ) ; final CompletableFuture onSuccess = cf . thenApplyAsync ( fn , getTaskExecutor ( ) ) ; return ( SimpleReactStream < R > ) withLastActive ( new EagerStreamWrapper ( onSuccess , getErrorHandler ( ) ) ) ; }
react to the completion of any of the events in the previous stage . will not work reliably with streams where filter has been applied in earlier stages . ( as filter completes the stream for events that are filtered out , they potentially shortcircuit the completion of the stage ) .
