com.spotify.flo

Class EvalContextWithTask

java.lang.Object

com.spotify.flo.context.ForwardingEvalContext

com.spotify.flo.EvalContextWithTask

All Implemented Interfaces:

EvalContext

public class EvalContextWithTask
extends ForwardingEvalContext

A EvalContext that overrides EvalContext.currentTask() to return a specific TaskId.

Nested Class Summary

Nested classes/interfaces inherited from interface com.spotify.flo.EvalContext

EvalContext.Promise<T>, EvalContext.Value<T>

Field Summary

Fields inherited from class com.spotify.flo.context.ForwardingEvalContext

delegate

Fields inherited from interface com.spotify.flo.EvalContext

LOG

Method Summary

Modifier and Type	Method and Description
Optional<Task<?>>	currentTask() When called during the evaluation of a task, this method will return the Task currently being processed.

Methods inherited from class com.spotify.flo.context.ForwardingEvalContext

evaluateInternal, immediateValue, invokeProcessFn, listener, promise, value

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.spotify.flo.EvalContext

async, evaluate, sync

Method Detail

currentTask

public Optional<Task<?>> currentTask()

Description copied from interface: EvalContext

When called during the evaluation of a task, this method will return the Task currently being processed. Otherwise an empty value will be returned.

The return value of this method is stable for each instance of EvalContext that is passed into the process functions. Calls from multiple threads will see the same result as longs as the calls are made to the same instance.

Returns:

The task that is being evaluated or empty if called from outside of a process function