< T , U > Stage < U > doEventuallyCollect ( final Collection < ? extends Callable < ? extends Stage < ? extends T > > > tasks , final Consumer < ? super T > consumer , Supplier < ? extends U > supplier , int parallelism ) { final ExecutorService executor = executor ( ) ; final Completable < U > stage = completable ( ) ; executor . execute ( new DelayedCollectCoordinator <> ( caller , tasks , consumer , supplier , stage , parallelism ) ) ; return stage ; }
Perform an eventual collection .