Class FutureStream<T extends Resource>

java.lang.Object

org.jdrupes.builder.core.FutureStream<T>

Type Parameters:

T - the provided resource type

public class FutureStream<T extends Resource>
extends Object

Evaluate the stream from a provider asynchronously.

Constructor Summary

Constructors

Constructor	Description
FutureStream(ExecutorService executor, ResourceProvider provider, ResourceRequest<T> requested)	Instantiates a new future resources.

Method Summary

Modifier and Type	Method	Description
static boolean	isProviderInvocationAllowed()	Checks if is provider invocation is allowed.
Stream<T>	stream()	Returns the lazily evaluated stream of resources.

Methods inherited from class Object

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

Constructor Details

FutureStream

public FutureStream(ExecutorService executor,
 ResourceProvider provider,
 ResourceRequest<T> requested)

Instantiates a new future resources.

Parameters:

executor - the executor

provider - the provider

requested - the requested

Method Details

isProviderInvocationAllowed

public static boolean isProviderInvocationAllowed()

Checks if is provider invocation is allowed. Clears the allowed flag to also detect nested invocations.

Returns:

true, if is provider invocation allowed

stream

public Stream<T> stream()

Returns the lazily evaluated stream of resources.

Returns:

the stream