Package com.github.basking2.sdsai.itrex.functions

Class ThreadFunction

java.lang.Object

com.github.basking2.sdsai.itrex.functions.ThreadFunction

All Implemented Interfaces:

FunctionInterface<Iterator<Future<Object>>>, BiFunction<Iterator<?>,EvaluationContext,Iterator<Future<Object>>>

public class ThreadFunction
extends Object
implements FunctionInterface<Iterator<Future<Object>>>

This takes a single iterator and, for each element in that iterator, returns a single element wrapped in a Future. Use join to unwrap the value in that future.

Constructor Summary

Constructors

Constructor	Description
ThreadFunction(Executor executor)

Method Summary

Modifier and Type	Method	Description
Iterator<Future<Object>>	apply(Iterator<?> iterator, EvaluationContext evaluationContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Constructor Details

ThreadFunction

public ThreadFunction(Executor executor)

Method Details

apply

public Iterator<Future<Object>> apply(Iterator<?> iterator,
 EvaluationContext evaluationContext)

Specified by:

apply in interface BiFunction<Iterator<?>,EvaluationContext,Iterator<Future<Object>>>