- accept(T1) - Method in interface com.linkedin.parseq.function.Consumer1
-
- accept(T1, T2) - Method in interface com.linkedin.parseq.function.Consumer2
-
- accept(T1, T2, T3) - Method in interface com.linkedin.parseq.function.Consumer3
-
- accept(T1, T2, T3, T4) - Method in interface com.linkedin.parseq.function.Consumer4
-
- accept(T1, T2, T3, T4, T5) - Method in interface com.linkedin.parseq.function.Consumer5
-
- accept(T1, T2, T3, T4, T5, T6) - Method in interface com.linkedin.parseq.function.Consumer6
-
- accept(T1, T2, T3, T4, T5, T6, T7) - Method in interface com.linkedin.parseq.function.Consumer7
-
- accept(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface com.linkedin.parseq.function.Consumer8
-
- accept(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface com.linkedin.parseq.function.Consumer9
-
- accept(Promise<S>, Settable<T>) - Method in class com.linkedin.parseq.promise.PromiseTransformer
-
- Action - Interface in com.linkedin.parseq.function
-
- action(String, Action) - Static method in interface com.linkedin.parseq.Task
-
Creates a new task that have a value of type Void
.
- action(Action) - Static method in interface com.linkedin.parseq.Task
-
Equivalent to action("action", action)
.
- action(String, Runnable) - Static method in class com.linkedin.parseq.Tasks
-
- ActionTask - Class in com.linkedin.parseq
-
- ActionTask(String, Runnable) - Constructor for class com.linkedin.parseq.ActionTask
-
Deprecated.
- addAttribute(String, String) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- addListener(PromiseListener<T>) - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- addListener(PromiseListener<P>) - Method in interface com.linkedin.parseq.promise.Promise
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<T>) - Method in class com.linkedin.parseq.promise.ResolvedError
-
- addListener(PromiseListener<T>) - Method in class com.linkedin.parseq.promise.ResolvedValue
-
- addListener(PromiseListener<Tuple2<T1, T2>>) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple3<T1, T2, T3>>) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple4<T1, T2, T3, T4>>) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple5<T1, T2, T3, T4, T5>>) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple6<T1, T2, T3, T4, T5, T6>>) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple7<T1, T2, T3, T4, T5, T6, T7>>) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>>) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addListener(PromiseListener<Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>>) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Adds a listener to this promise that will be notified when the promise is
resolved.
- addRelationship(Relationship, ShallowTraceBuilder, ShallowTraceBuilder) - Method in class com.linkedin.parseq.trace.TraceBuilder
-
- addShallowTrace(ShallowTraceBuilder) - Method in class com.linkedin.parseq.trace.TraceBuilder
-
- After - Interface in com.linkedin.parseq
-
An object that invokes tasks after as set of
Promise
s and
Task
s have completed.
- after(Promise<?>...) - Method in interface com.linkedin.parseq.Context
-
Provides a mechanism of ordering the execution of some child tasks after
the resolution of the given promises (which may also be tasks).
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function1
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function2
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function3
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function4
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function5
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function6
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function7
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function8
-
- andThen(Function1<? super R, ? extends V>) - Method in interface com.linkedin.parseq.function.Function9
-
- andThen(String, Consumer1<? super T>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer1<? super T>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Task<R>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task which runs given task after
completion of this task and completes with a result of
that task.
- andThen(Task<R>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to andThen("andThen", task)
.
- andThen(Consumer2<T1, T2>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer2<T1, T2>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer3<T1, T2, T3>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer3<T1, T2, T3>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer4<T1, T2, T3, T4>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer4<T1, T2, T3, T4>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer5<T1, T2, T3, T4, T5>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer5<T1, T2, T3, T4, T5>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer6<T1, T2, T3, T4, T5, T6>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer6<T1, T2, T3, T4, T5, T6>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer7<T1, T2, T3, T4, T5, T6, T7>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer7<T1, T2, T3, T4, T5, T6, T7>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer8<T1, T2, T3, T4, T5, T6, T7, T8>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer8<T1, T2, T3, T4, T5, T6, T7, T8>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- andThen(Consumer9<T1, T2, T3, T4, T5, T6, T7, T8, T9>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to andThen("andThen", consumer)
.
- andThen(String, Consumer9<T1, T2, T3, T4, T5, T6, T7, T8, T9>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task which applies a consumer to the result of this task
and completes with a result of this task.
- apply(T1) - Method in interface com.linkedin.parseq.function.Function1
-
- apply(T1, T2) - Method in interface com.linkedin.parseq.function.Function2
-
- apply(T1, T2, T3) - Method in interface com.linkedin.parseq.function.Function3
-
- apply(T1, T2, T3, T4) - Method in interface com.linkedin.parseq.function.Function4
-
- apply(T1, T2, T3, T4, T5) - Method in interface com.linkedin.parseq.function.Function5
-
- apply(T1, T2, T3, T4, T5, T6) - Method in interface com.linkedin.parseq.function.Function6
-
- apply(T1, T2, T3, T4, T5, T6, T7) - Method in interface com.linkedin.parseq.function.Function7
-
- apply(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface com.linkedin.parseq.function.Function8
-
- apply(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface com.linkedin.parseq.function.Function9
-
- apply(String, PromisePropagator<T, R>) - Method in interface com.linkedin.parseq.Task
-
- arity() - Method in interface com.linkedin.parseq.function.Tuple
-
- arity() - Method in class com.linkedin.parseq.function.Tuple2
-
- arity() - Method in class com.linkedin.parseq.function.Tuple3
-
- arity() - Method in class com.linkedin.parseq.function.Tuple4
-
- arity() - Method in class com.linkedin.parseq.function.Tuple5
-
- arity() - Method in class com.linkedin.parseq.function.Tuple6
-
- arity() - Method in class com.linkedin.parseq.function.Tuple7
-
- arity() - Method in class com.linkedin.parseq.function.Tuple8
-
- arity() - Method in class com.linkedin.parseq.function.Tuple9
-
- async(String, Callable<Promise<? extends T>>) - Static method in interface com.linkedin.parseq.Task
-
Creates a new task from a callable that returns a
Promise
.
- async(Callable<Promise<? extends T>>) - Static method in interface com.linkedin.parseq.Task
-
Equivalent to async("async", callable)
.
- async(String, Function1<Context, Promise<? extends T>>) - Static method in interface com.linkedin.parseq.Task
-
Creates a new task from a callable that returns a
Promise
.
- async(Function1<Context, Promise<? extends T>>) - Static method in interface com.linkedin.parseq.Task
-
Equivalent to async("async", func)
.
- AsyncCallableTask<R> - Class in com.linkedin.parseq
-
- AsyncCallableTask(Callable<R>) - Constructor for class com.linkedin.parseq.AsyncCallableTask
-
- AsyncCallableTask(String, Callable<R>) - Constructor for class com.linkedin.parseq.AsyncCallableTask
-
- await() - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- await(long, TimeUnit) - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- await() - Method in interface com.linkedin.parseq.promise.Promise
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in interface com.linkedin.parseq.promise.Promise
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.promise.ResolvedError
-
- await(long, TimeUnit) - Method in class com.linkedin.parseq.promise.ResolvedError
-
- await() - Method in class com.linkedin.parseq.promise.ResolvedValue
-
- await(long, TimeUnit) - Method in class com.linkedin.parseq.promise.ResolvedValue
-
- await() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- await() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Blocks the current thread for an unbounded amount of time until the promise
has be resolved.
- await(long, TimeUnit) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Blocks the current thread for up to the specified amount of time or until
the promise has been resolved.
- awaitTermination(int, TimeUnit) - Method in class com.linkedin.parseq.Engine
-
Waits for the engine to stop.
- call() - Method in interface com.linkedin.parseq.ThrowableCallable
-
Deprecated.
Computes a value of type T
or throws a Throwable
if an
error occurred during the computation.
- callable(String, Callable<? extends T>) - Static method in interface com.linkedin.parseq.Task
-
Creates a new task that's value will be set to the value returned
from the supplied callable.
- callable(Callable<? extends T>) - Static method in interface com.linkedin.parseq.Task
-
Equivalent to callable("callable", callable)
.
- callable(String, Callable<? extends T>) - Static method in class com.linkedin.parseq.Tasks
-
- callable(String, ThrowableCallable<? extends T>) - Static method in class com.linkedin.parseq.Tasks
-
- CallableTask<T> - Class in com.linkedin.parseq
-
- CallableTask(String, Callable<? extends T>) - Constructor for class com.linkedin.parseq.CallableTask
-
Deprecated.
- CallableTask(String, ThrowableCallable<? extends T>) - Constructor for class com.linkedin.parseq.CallableTask
-
Deprecated.
- cancel(Exception) - Method in class com.linkedin.parseq.BaseTask
-
- cancel(Exception) - Method in interface com.linkedin.parseq.Cancellable
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Attempts to cancel the object with the given reason.
- cancel(Exception) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Attempts to cancel the object with the given reason.
- Cancellable - Interface in com.linkedin.parseq
-
An object that can be cancelled with a reason.
- cast(Task<Tuple2<T1, T2>>) - Static method in interface com.linkedin.parseq.Tuple2Task
-
- cast(Task<Tuple3<T1, T2, T3>>) - Static method in interface com.linkedin.parseq.Tuple3Task
-
- cast(Task<Tuple4<T1, T2, T3, T4>>) - Static method in interface com.linkedin.parseq.Tuple4Task
-
- cast(Task<Tuple5<T1, T2, T3, T4, T5>>) - Static method in interface com.linkedin.parseq.Tuple5Task
-
- cast(Task<Tuple6<T1, T2, T3, T4, T5, T6>>) - Static method in interface com.linkedin.parseq.Tuple6Task
-
- cast(Task<Tuple7<T1, T2, T3, T4, T5, T6, T7>>) - Static method in interface com.linkedin.parseq.Tuple7Task
-
- cast(Task<Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>>) - Static method in interface com.linkedin.parseq.Tuple8Task
-
- cast(Task<Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>>) - Static method in interface com.linkedin.parseq.Tuple9Task
-
- com.linkedin.parseq - package com.linkedin.parseq
-
Core ParSeq classes.
- com.linkedin.parseq.function - package com.linkedin.parseq.function
-
- com.linkedin.parseq.promise - package com.linkedin.parseq.promise
-
Promises are like Future
s, but they provide
a listener mechanism to wait for completion asynchronously.
- com.linkedin.parseq.trace - package com.linkedin.parseq.trace
-
Tracing related APIs and functionality.
- com.linkedin.parseq.trace.codec - package com.linkedin.parseq.trace.codec
-
- com.linkedin.parseq.trace.codec.json - package com.linkedin.parseq.trace.codec.json
-
- compose(PromisePropagator<T, R>) - Method in interface com.linkedin.parseq.promise.PromisePropagator
-
- compose(PromisePropagator<T, R>) - Method in class com.linkedin.parseq.promise.PromiseTransformer
-
- Consumer1<T1> - Interface in com.linkedin.parseq.function
-
- Consumer2<T1,T2> - Interface in com.linkedin.parseq.function
-
- Consumer3<T1,T2,T3> - Interface in com.linkedin.parseq.function
-
- Consumer4<T1,T2,T3,T4> - Interface in com.linkedin.parseq.function
-
- Consumer5<T1,T2,T3,T4,T5> - Interface in com.linkedin.parseq.function
-
- Consumer6<T1,T2,T3,T4,T5,T6> - Interface in com.linkedin.parseq.function
-
- Consumer7<T1,T2,T3,T4,T5,T6,T7> - Interface in com.linkedin.parseq.function
-
- Consumer8<T1,T2,T3,T4,T5,T6,T7,T8> - Interface in com.linkedin.parseq.function
-
- Consumer9<T1,T2,T3,T4,T5,T6,T7,T8,T9> - Interface in com.linkedin.parseq.function
-
- containsRelationship(TraceRelationship) - Method in class com.linkedin.parseq.trace.TraceBuilder
-
- Context - Interface in com.linkedin.parseq
-
A context provides an API to
Task
s for the purpose of scheduling
other tasks.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.BaseTask
-
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in interface com.linkedin.parseq.Task
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Attempts to run the task with the given context.
- contextRun(Context, Task<?>, Collection<Task<?>>) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Attempts to run the task with the given context.
- CountDownPromiseListener<T> - Class in com.linkedin.parseq.promise
-
Sets a value on a
SettablePromise
after this listener has been
notified of a specified number of promise resolutions.
- CountDownPromiseListener(int, SettablePromise<T>, T) - Constructor for class com.linkedin.parseq.promise.CountDownPromiseListener
-
- createTimer(long, TimeUnit, Task<?>) - Method in interface com.linkedin.parseq.Context
-
Creates a timer that will invoke the given task if the calling task has
not yet finished.
- fail(Throwable) - Method in interface com.linkedin.parseq.promise.Settable
-
Sets an error on this promise.
- Failure<T> - Class in com.linkedin.parseq.function
-
- failure(String, Throwable) - Static method in interface com.linkedin.parseq.Task
-
Creates a new task that will be fail with given exception when it is
executed.
- failure(Throwable) - Static method in interface com.linkedin.parseq.Task
-
Equivalent to failure("failure", failure)
.
- failureToString(Throwable) - Static method in class com.linkedin.parseq.Exceptions
-
- FastFailCountDownPromiseListener<T> - Class in com.linkedin.parseq.promise
-
Sets a value on a
SettablePromise
after this listener has been
notified of a specified number of promise resolutions.
- FastFailCountDownPromiseListener(int, SettablePromise<T>, T) - Constructor for class com.linkedin.parseq.promise.FastFailCountDownPromiseListener
-
- flatMap(String, Function1<? super T, Task<R>>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function1<? super T, Task<R>>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to flatMap("flatMap", func)
.
- flatMap(Function2<T1, T2, Task<R>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function2<T1, T2, Task<R>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function3<T1, T2, T3, Task<R>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function3<T1, T2, T3, Task<R>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function4<T1, T2, T3, T4, Task<R>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function4<T1, T2, T3, T4, Task<R>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function5<T1, T2, T3, T4, T5, Task<R>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function5<T1, T2, T3, T4, T5, Task<R>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function6<T1, T2, T3, T4, T5, T6, Task<R>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function6<T1, T2, T3, T4, T5, T6, Task<R>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function7<T1, T2, T3, T4, T5, T6, T7, Task<R>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function7<T1, T2, T3, T4, T5, T6, T7, Task<R>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function8<T1, T2, T3, T4, T5, T6, T7, T8, Task<R>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function8<T1, T2, T3, T4, T5, T6, T7, T8, Task<R>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatMap(Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, Task<R>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to flatMap("flatMap", f)
.
- flatMap(String, Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, Task<R>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task by applying a function to the successful result of this task and
returns the result of a function as the new task.
- flatten(String, Task<Task<R>>) - Static method in interface com.linkedin.parseq.Task
-
Converts Task<Task<R>>
into Task<R>
.
- flatten(Task<Task<R>>) - Static method in interface com.linkedin.parseq.Task
-
Equivalent to flatten("flatten", task)
.
- fromTask(Task<?>) - Static method in enum com.linkedin.parseq.trace.ResultType
-
Given a task this method will return a
ResultType
classification.
- Function1<T1,R> - Interface in com.linkedin.parseq.function
-
- Function2<T1,T2,R> - Interface in com.linkedin.parseq.function
-
- Function3<T1,T2,T3,R> - Interface in com.linkedin.parseq.function
-
- Function4<T1,T2,T3,T4,R> - Interface in com.linkedin.parseq.function
-
- Function5<T1,T2,T3,T4,T5,R> - Interface in com.linkedin.parseq.function
-
- Function6<T1,T2,T3,T4,T5,T6,R> - Interface in com.linkedin.parseq.function
-
- Function7<T1,T2,T3,T4,T5,T6,T7,R> - Interface in com.linkedin.parseq.function
-
- Function8<T1,T2,T3,T4,T5,T6,T7,T8,R> - Interface in com.linkedin.parseq.function
-
- Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> - Interface in com.linkedin.parseq.function
-
- get() - Method in class com.linkedin.parseq.function.Failure
-
- get() - Method in class com.linkedin.parseq.function.Success
-
- get() - Method in interface com.linkedin.parseq.function.Try
-
Returns value associated with successful completion or
NoSuchElementException
if result represents a failure.
- get() - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- get() - Method in interface com.linkedin.parseq.promise.Promise
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.promise.ResolvedError
-
- get() - Method in class com.linkedin.parseq.promise.ResolvedValue
-
- get() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
If the promise's value is set, then this method returns the value.
- get() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
If the promise's value is set, then this method returns the value.
- getAttributes() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Get the set of attributes related to this trace.
- getAttributes() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getAttributes() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getCauses() - Method in exception com.linkedin.parseq.MultiException
-
- getDelegate() - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- getEndNanos() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns the time at which the task was finished in nanoseconds.
- getEndNanos() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getEndNanos() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getEngineProperty(String) - Method in interface com.linkedin.parseq.Context
-
Provides a mechanism for "plugins" to generate data which should be passed in via the context.
- getError() - Method in class com.linkedin.parseq.function.Failure
-
- getError() - Method in class com.linkedin.parseq.function.Success
-
- getError() - Method in interface com.linkedin.parseq.function.Try
-
Returns Throwable
associated with this failure or
null if result represents successful completion.
- getError() - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- getError() - Method in interface com.linkedin.parseq.promise.Promise
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.promise.ResolvedError
-
- getError() - Method in class com.linkedin.parseq.promise.ResolvedValue
-
- getError() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Returns the error in this promise, if there is one.
- getError() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Returns the error in this promise, if there is one.
- getFrom() - Method in class com.linkedin.parseq.trace.TraceRelationship
-
- getHidden() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns if the trace will be hidden from the visualizations.
- getHidden() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getHidden() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getId() - Method in class com.linkedin.parseq.BaseTask
-
- getId() - Method in interface com.linkedin.parseq.Task
-
Unique identifier of the task.
- getId() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Id of this trace.
- getId() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getId() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getId() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Unique identifier of the task.
- getId() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Unique identifier of the task.
- getJsonTrace(Task<?>) - Static method in class com.linkedin.parseq.trace.TraceUtil
-
Returns trace of a task serialized to a JSON string.
- getName() - Method in class com.linkedin.parseq.BaseTask
-
Returns the name of this task.
- getName() - Method in interface com.linkedin.parseq.Task
-
Returns the name of this task.
- getName() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns the task name for this trace
- getName() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getName() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getName() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Returns the name of this task.
- getName() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Returns the name of this task.
- getOrDefault(T) - Method in class com.linkedin.parseq.promise.DelegatingPromise
-
- getOrDefault(P) - Method in interface com.linkedin.parseq.promise.Promise
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(T) - Method in class com.linkedin.parseq.promise.ResolvedError
-
- getOrDefault(T) - Method in class com.linkedin.parseq.promise.ResolvedValue
-
- getOrDefault(Tuple2<T1, T2>) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple3<T1, T2, T3>) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple4<T1, T2, T3, T4>) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple5<T1, T2, T3, T4, T5>) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple6<T1, T2, T3, T4, T5, T6>) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple7<T1, T2, T3, T4, T5, T6, T7>) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getOrDefault(Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Gets the value in this promise or, if the promise contains an error,
returns the given default value.
- getPendingNanos() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns the time at which the task finished its run method in nanoseconds.
- getPendingNanos() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getPendingNanos() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getPlanId() - Method in interface com.linkedin.parseq.Context
-
- getPriority() - Method in class com.linkedin.parseq.BaseTask
-
- getPriority() - Method in class com.linkedin.parseq.BaseTask.State
-
- getPriority() - Method in interface com.linkedin.parseq.Task
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Returns the priority for this task.
- getPriority() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Returns the priority for this task.
- getProperty(String) - Method in class com.linkedin.parseq.Engine
-
- getRelationhsip() - Method in class com.linkedin.parseq.trace.TraceRelationship
-
- getRelationships() - Method in class com.linkedin.parseq.trace.Trace
-
- getResultType() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns the result type of the task.
- getResultType() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getResultType() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getSettableDelegate() - Method in class com.linkedin.parseq.BaseTask
-
- getShallowTrace() - Method in class com.linkedin.parseq.BaseTask
-
- getShallowTrace() - Method in interface com.linkedin.parseq.Task
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTrace() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Returns the ShallowTrace for this task.
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.BaseTask
-
- getShallowTraceBuilder() - Method in interface com.linkedin.parseq.Context
-
- getShallowTraceBuilder() - Method in interface com.linkedin.parseq.Task
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
- getShallowTraceBuilder() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
- getStartNanos() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns the time at which the task was started in nanoseconds.
- getStartNanos() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getStartNanos() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getSuccessful() - Method in interface com.linkedin.parseq.ParTask
-
Get the list of successful values.
- getSystemHidden() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns if the trace will be system hidden from the visualizations.
- getSystemHidden() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getSystemHidden() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- getTaskId() - Method in interface com.linkedin.parseq.Context
-
- getTaskLogger() - Method in interface com.linkedin.parseq.Context
-
- getTasks() - Method in interface com.linkedin.parseq.ParTask
-
Return the list of tasks that were related to this task.
- getTo() - Method in class com.linkedin.parseq.trace.TraceRelationship
-
- getTrace() - Method in class com.linkedin.parseq.BaseTask
-
- getTrace() - Method in interface com.linkedin.parseq.Task
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Returns the Trace for this task.
- getTrace() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Returns the Trace for this task.
- getTraceBuilder() - Method in class com.linkedin.parseq.BaseTask
-
- getTraceBuilder() - Method in interface com.linkedin.parseq.Context
-
- getTraceBuilder() - Method in interface com.linkedin.parseq.Task
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
- getTraceBuilder() - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
- getTraceMap() - Method in class com.linkedin.parseq.trace.Trace
-
- getType() - Method in class com.linkedin.parseq.BaseTask.State
-
- getValue() - Method in interface com.linkedin.parseq.trace.ShallowTrace
-
Returns a String representation of the value or error produced by the
traced task.
- getValue() - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- getValue() - Method in class com.linkedin.parseq.trace.ShallowTraceImp
-
- map(Function2<T1, T2, C>) - Method in class com.linkedin.parseq.function.Tuple2
-
- map(Function3<T1, T2, T3, C>) - Method in class com.linkedin.parseq.function.Tuple3
-
- map(Function4<T1, T2, T3, T4, C>) - Method in class com.linkedin.parseq.function.Tuple4
-
- map(Function5<T1, T2, T3, T4, T5, C>) - Method in class com.linkedin.parseq.function.Tuple5
-
- map(Function6<T1, T2, T3, T4, T5, T6, C>) - Method in class com.linkedin.parseq.function.Tuple6
-
- map(Function7<T1, T2, T3, T4, T5, T6, T7, C>) - Method in class com.linkedin.parseq.function.Tuple7
-
- map(Function8<T1, T2, T3, T4, T5, T6, T7, T8, C>) - Method in class com.linkedin.parseq.function.Tuple8
-
- map(Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, C>) - Method in class com.linkedin.parseq.function.Tuple9
-
- map(String, Function1<? super T, ? extends R>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function1<? super T, ? extends R>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to map("map", func)
.
- map(Function2<T1, T2, R>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to map("map", f)
.
- map(String, Function2<T1, T2, R>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function3<T1, T2, T3, R>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to map("map", f)
.
- map(String, Function3<T1, T2, T3, R>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function4<T1, T2, T3, T4, R>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to map("map", f)
.
- map(String, Function4<T1, T2, T3, T4, R>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function5<T1, T2, T3, T4, T5, R>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to map("map", f)
.
- map(String, Function5<T1, T2, T3, T4, T5, R>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function6<T1, T2, T3, T4, T5, T6, R>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to map("map", f)
.
- map(String, Function6<T1, T2, T3, T4, T5, T6, R>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function7<T1, T2, T3, T4, T5, T6, T7, R>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to map("map", f)
.
- map(String, Function7<T1, T2, T3, T4, T5, T6, T7, R>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function8<T1, T2, T3, T4, T5, T6, T7, T8, R>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to map("map", f)
.
- map(String, Function8<T1, T2, T3, T4, T5, T6, T7, T8, R>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task by applying a function to the successful result of this task.
- map(Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to map("map", f)
.
- map(String, Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task by applying a function to the successful result of this task.
- markTaskPending() - Method in class com.linkedin.parseq.BaseTask
-
- markTaskStarted() - Method in class com.linkedin.parseq.BaseTask
-
- MAX_PRIORITY - Static variable in class com.linkedin.parseq.Priority
-
Tasks with maximum priority will be executed before all other tasks.
- MAX_RELATIONSHIPS_PER_TRACE - Static variable in class com.linkedin.parseq.Engine
-
- MIN_PRIORITY - Static variable in class com.linkedin.parseq.Priority
-
Tasks with minimum priority will only be executed after all other tasks
have been executed.
- MultiException - Exception in com.linkedin.parseq
-
An exception representing multiple exceptions.
- MultiException(String, Collection<? extends Throwable>) - Constructor for exception com.linkedin.parseq.MultiException
-
- MultiException(Collection<? extends Throwable>) - Constructor for exception com.linkedin.parseq.MultiException
-
- of(Throwable) - Static method in class com.linkedin.parseq.function.Failure
-
- of(R) - Static method in class com.linkedin.parseq.function.Success
-
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onFailure(Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to onFailure("onFailure", consumer)
.
- onFailure(String, Consumer1<Throwable>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task which applies a consumer to the exception this
task may fail with.
- onResolved(Promise<T>) - Method in class com.linkedin.parseq.promise.CountDownPromiseListener
-
- onResolved(Promise<T>) - Method in class com.linkedin.parseq.promise.FastFailCountDownPromiseListener
-
- onResolved(Promise<P>) - Method in interface com.linkedin.parseq.promise.PromiseListener
-
A callback method that is invoked when the promise completes.
- onResolved(Promise<S>) - Method in class com.linkedin.parseq.promise.TransformingPromiseListener
-
- recover(String, Function1<Throwable, T>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, T>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to recover("recover", func)
.
- recover(Function1<Throwable, Tuple2<T1, T2>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple2<T1, T2>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple3<T1, T2, T3>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple3<T1, T2, T3>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple4<T1, T2, T3, T4>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple4<T1, T2, T3, T4>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple5<T1, T2, T3, T4, T5>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple5<T1, T2, T3, T4, T5>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple6<T1, T2, T3, T4, T5, T6>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple6<T1, T2, T3, T4, T5, T6>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple7<T1, T2, T3, T4, T5, T6, T7>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple7<T1, T2, T3, T4, T5, T6, T7>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task that will handle failure of this task.
- recover(Function1<Throwable, Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to recover("recover", func)
.
- recover(String, Function1<Throwable, Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task that will handle failure of this task.
- recoverWith(String, Function1<Throwable, Task<T>>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<T>>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(Function1<Throwable, Task<Tuple2<T1, T2>>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple2<T1, T2>>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple3<T1, T2, T3>>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple3<T1, T2, T3>>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple4<T1, T2, T3, T4>>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple4<T1, T2, T3, T4>>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple5<T1, T2, T3, T4, T5>>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple5<T1, T2, T3, T4, T5>>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple6<T1, T2, T3, T4, T5, T6>>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple6<T1, T2, T3, T4, T5, T6>>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple7<T1, T2, T3, T4, T5, T6, T7>>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple7<T1, T2, T3, T4, T5, T6, T7>>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task that will handle failure of this task.
- recoverWith(Function1<Throwable, Task<Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to recoverWith("recoverWith", func)
.
- recoverWith(String, Function1<Throwable, Task<Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task that will handle failure of this task.
- register(EngineBuilder, Executor) - Static method in class com.linkedin.parseq.AsyncCallableTask
-
Deprecated.
- Relationship - Enum in com.linkedin.parseq.trace
-
A list of relationship types used by the trace system.
- removeAttribute(String) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- ResolvedError<T> - Class in com.linkedin.parseq.promise
-
- ResolvedError(Throwable) - Constructor for class com.linkedin.parseq.promise.ResolvedError
-
- ResolvedValue<T> - Class in com.linkedin.parseq.promise
-
- ResolvedValue(T) - Constructor for class com.linkedin.parseq.promise.ResolvedValue
-
- resultType() - Method in class com.linkedin.parseq.function.Failure
-
- resultType() - Method in class com.linkedin.parseq.function.Success
-
- resultType() - Method in interface com.linkedin.parseq.function.Try
-
- ResultType - Enum in com.linkedin.parseq.trace
-
An enumeration that classifies the state of a Task.
- run(Context) - Method in class com.linkedin.parseq.ActionTask
-
Deprecated.
- run(Task<?>) - Method in interface com.linkedin.parseq.After
-
When all promises and tasks have been resolved then the given task is
run.
- run(Supplier<Task<?>>) - Method in interface com.linkedin.parseq.After
-
When all promises and tasks have been resolved then task provided by
given Supplier is run.
- run(Context) - Method in class com.linkedin.parseq.AsyncCallableTask
-
Deprecated.
- run(Context) - Method in class com.linkedin.parseq.BaseTask
-
This template method is invoked when the task is run.
- RUN - Static variable in class com.linkedin.parseq.BaseTask.State
-
- run(Context) - Method in class com.linkedin.parseq.CallableTask
-
Deprecated.
- run(Task<?>...) - Method in interface com.linkedin.parseq.Context
-
Runs one or more tasks in parallel.
- run(Task<?>) - Method in class com.linkedin.parseq.Engine
-
Runs the given task with its own context.
- run(Task<?>, String) - Method in class com.linkedin.parseq.Engine
-
Runs the given task with its own context.
- run() - Method in interface com.linkedin.parseq.function.Action
-
- run(Context) - Method in class com.linkedin.parseq.Par2Task
-
- run(Context) - Method in class com.linkedin.parseq.Par3Task
-
- run(Context) - Method in class com.linkedin.parseq.Par4Task
-
- run(Context) - Method in class com.linkedin.parseq.Par5Task
-
- run(Context) - Method in class com.linkedin.parseq.Par6Task
-
- run(Context) - Method in class com.linkedin.parseq.Par7Task
-
- run(Context) - Method in class com.linkedin.parseq.Par8Task
-
- run(Context) - Method in class com.linkedin.parseq.Par9Task
-
- runSideEffect(Task<?>) - Method in interface com.linkedin.parseq.After
-
When all promises and tasks have been resolved successfully, the given
task is run as a side effect.
- runSideEffect(Task<?>...) - Method in interface com.linkedin.parseq.Context
-
- schedule(long, TimeUnit, Runnable) - Method in interface com.linkedin.parseq.DelayedExecutor
-
Schedules a command to execute after some period of delay.
- schedule(long, TimeUnit, Runnable) - Method in class com.linkedin.parseq.DelayedExecutorAdapter
-
- seq(Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<?>, Task<T>) - Static method in class com.linkedin.parseq.Tasks
-
- seq(Iterable<? extends Task<?>>) - Static method in class com.linkedin.parseq.Tasks
-
- setEndNanos(Long) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- setEngineProperty(String, Object) - Method in class com.linkedin.parseq.EngineBuilder
-
Sets an engine related property on the engine.
- setHidden(boolean) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- setLoggerFactory(ILoggerFactory) - Method in class com.linkedin.parseq.EngineBuilder
-
Sets the logger factory that will be used by the engine.
- setName(String) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- setPendingNanos(Long) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- setPriority(int) - Method in class com.linkedin.parseq.BaseTask
-
- setPriority(int) - Method in interface com.linkedin.parseq.Task
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
Overrides the priority for this task.
- setPriority(int) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
Overrides the priority for this task.
- setResultType(ResultType) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- setStartNanos(Long) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- setSystemHidden(boolean) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- settable() - Static method in class com.linkedin.parseq.promise.Promises
-
Returns a new promise that can have its value set at a later time.
- Settable<P> - Interface in com.linkedin.parseq.promise
-
- SettablePromise<P> - Interface in com.linkedin.parseq.promise
-
A
Promise
that can have its value set.
- setTaskExecutor(Executor) - Method in class com.linkedin.parseq.EngineBuilder
-
Sets the task executor for the engine.
- setTimerScheduler(DelayedExecutor) - Method in class com.linkedin.parseq.EngineBuilder
-
Sets the timer scheduler for the engine.
- setTimerScheduler(ScheduledExecutorService) - Method in class com.linkedin.parseq.EngineBuilder
-
Sets the timer scheduler for the engine.
- setTraceValueSerializer(Function<T, String>) - Method in class com.linkedin.parseq.BaseTask
-
- setTraceValueSerializer(Function<T, String>) - Method in interface com.linkedin.parseq.Task
-
Allows adding String
representation of value computed by this task to trace.
- setTraceValueSerializer(Function<Tuple2<T1, T2>, String>) - Method in class com.linkedin.parseq.Tuple2TaskDelegate
-
- setTraceValueSerializer(Function<Tuple3<T1, T2, T3>, String>) - Method in class com.linkedin.parseq.Tuple3TaskDelegate
-
- setTraceValueSerializer(Function<Tuple4<T1, T2, T3, T4>, String>) - Method in class com.linkedin.parseq.Tuple4TaskDelegate
-
- setTraceValueSerializer(Function<Tuple5<T1, T2, T3, T4, T5>, String>) - Method in class com.linkedin.parseq.Tuple5TaskDelegate
-
- setTraceValueSerializer(Function<Tuple6<T1, T2, T3, T4, T5, T6>, String>) - Method in class com.linkedin.parseq.Tuple6TaskDelegate
-
- setTraceValueSerializer(Function<Tuple7<T1, T2, T3, T4, T5, T6, T7>, String>) - Method in class com.linkedin.parseq.Tuple7TaskDelegate
-
- setTraceValueSerializer(Function<Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>, String>) - Method in class com.linkedin.parseq.Tuple8TaskDelegate
-
- setTraceValueSerializer(Function<Tuple9<T1, T2, T3, T4, T5, T6, T7, T8, T9>, String>) - Method in class com.linkedin.parseq.Tuple9TaskDelegate
-
- setValue(String) - Method in class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- ShallowTrace - Interface in com.linkedin.parseq.trace
-
A shallow trace is a trace without any relationship information.
- ShallowTraceBuilder - Class in com.linkedin.parseq.trace
-
- ShallowTraceBuilder(Long) - Constructor for class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- ShallowTraceBuilder(ShallowTrace) - Constructor for class com.linkedin.parseq.trace.ShallowTraceBuilder
-
- ShallowTraceImp - Class in com.linkedin.parseq.trace
-
A shallow trace is a trace without any relationship information.
- shareable() - Method in interface com.linkedin.parseq.Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shareable() - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task that can be safely shared within a plan or between multiple
plans.
- shutdown() - Method in class com.linkedin.parseq.Engine
-
If the engine is currently running, this method will initiate an orderly
shutdown.
- single(ShallowTrace) - Static method in class com.linkedin.parseq.trace.Trace
-
- Success<T> - Class in com.linkedin.parseq.function
-
- withSideEffect(String, Function1<? super T, Task<?>>) - Method in interface com.linkedin.parseq.Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function1<? super T, Task<?>>) - Method in interface com.linkedin.parseq.Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(Task<T>, Task<?>) - Static method in class com.linkedin.parseq.Tasks
-
- withSideEffect(Function2<T1, T2, Task<?>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function2<T1, T2, Task<?>>) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function3<T1, T2, T3, Task<?>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function3<T1, T2, T3, Task<?>>) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function4<T1, T2, T3, T4, Task<?>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function4<T1, T2, T3, T4, Task<?>>) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function5<T1, T2, T3, T4, T5, Task<?>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function5<T1, T2, T3, T4, T5, Task<?>>) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function6<T1, T2, T3, T4, T5, T6, Task<?>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function6<T1, T2, T3, T4, T5, T6, Task<?>>) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function7<T1, T2, T3, T4, T5, T6, T7, Task<?>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function7<T1, T2, T3, T4, T5, T6, T7, Task<?>>) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function8<T1, T2, T3, T4, T5, T6, T7, T8, Task<?>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function8<T1, T2, T3, T4, T5, T6, T7, T8, Task<?>>) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withSideEffect(Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, Task<?>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Equivalent to withSideEffect("sideEffect", func)
.
- withSideEffect(String, Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, Task<?>>) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task that will run another task as a side effect once the primary task
completes successfully.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple2Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple3Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple4Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple5Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple6Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple7Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple8Task
-
Creates a new task that has a timeout associated with it.
- withTimeout(long, TimeUnit) - Method in interface com.linkedin.parseq.Tuple9Task
-
Creates a new task that has a timeout associated with it.