Index

A C D E F G I K M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

accept(Runnable) - Method in interface org.ores.async.Asyncc.IAcceptRunnable

acquire(long, Asyncc.IAsyncCallback<Unlock, Object>) - Method in class org.ores.async.NeoLock

Acquire the lock with a bounded wait.

acquire(Asyncc.IAsyncCallback<Unlock, Object>) - Method in class org.ores.async.NeoLock

acquireRead(long, Asyncc.IAsyncCallback<Unlock, Object>) - Method in class org.ores.async.NeoRwLock

Acquire a read lock with a bounded wait.

acquireRead(Asyncc.IAsyncCallback<Unlock, Object>) - Method in class org.ores.async.NeoRwLock

Acquire a read lock.

acquireWrite(long, Asyncc.IAsyncCallback<Unlock, Object>) - Method in class org.ores.async.NeoRwLock

Acquire a write lock with a bounded wait.

acquireWrite(Asyncc.IAsyncCallback<Unlock, Object>) - Method in class org.ores.async.NeoRwLock

Acquire a write lock.

Asyncc - Class in org.ores.async

Entry point for async.java's combinators.

Asyncc() - Constructor for class org.ores.async.Asyncc

Asyncc.AsyncCallback<T,E> - Class in org.ores.async

Asyncc.AsyncTask<T,E> - Interface in org.ores.async

Asyncc.AsyncValueTask<T,E> - Interface in org.ores.async

Asyncc.IAcceptRunnable - Interface in org.ores.async

Asyncc.IAsyncCallback<T,E> - Interface in org.ores.async

Error-first callback (Node.js-style).

Asyncc.ICallbacks<T,E> - Interface in org.ores.async

Asyncc.IMapper<T,V,E> - Interface in org.ores.async

Asyncc.KeyValue<K,V> - Class in org.ores.async

Asyncc.Overloader - Enum Class in org.ores.async

AsyncCallback(ShortCircuit) - Constructor for class org.ores.async.Asyncc.AsyncCallback

AsyncCallback(ShortCircuit) - Constructor for class org.ores.async.NeoGroupByI.AsyncCallback

AsyncCallback(ShortCircuit) - Constructor for class org.ores.async.NeoMapI.AsyncCallback

AsyncCallback(ShortCircuit) - Constructor for class org.ores.async.NeoWhilstI.AsyncCallback

AsyncCallback(ShortCircuit, HashMap<String, Object>) - Constructor for class org.ores.async.NeoWaterfallI.AsyncCallback

AsyncCallbackSet(ShortCircuit, Map<String, Object>) - Constructor for class org.ores.async.NeoInjectI.AsyncCallbackSet

C

cbLock - Variable in class org.ores.async.Asyncc.AsyncCallback

Concat(int, List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Concat(int, List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

Concat(List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Concat(List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatDeep(List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatDeep(List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatDeepLimit(int, List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatDeepLimit(int, List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatDeepSeries(List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatDeepSeries(List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatLimit(int, int, List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatLimit(int, int, List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatLimit(int, List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatLimit(int, List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatSeries(int, List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatSeries(int, List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

ConcatSeries(List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

ConcatSeries(List<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

curr - Variable in class org.ores.async.NeoReduceI.ReduceArg

D

discard() - Method in class org.ores.async.NeoFilterI.AsyncCallback

discard() - Method in class org.ores.async.NeoFilterMapI.AsyncCallback

done(E) - Method in interface org.ores.async.NeoEachI.IEachCallback

done(E) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

done(E) - Method in interface org.ores.async.NeoWaterfallI.IAsyncCallback

done(E, String, T) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

done(E, String, T) - Method in interface org.ores.async.NeoWaterfallI.IAsyncCallback

done(E, Map.Entry<String, T>) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

done(E, Map.Entry<String, T>) - Method in interface org.ores.async.NeoWaterfallI.IAsyncCallback

done(E, Optional<T>) - Method in class org.ores.async.NeoFilterMapI.AsyncCallback

done(E, T) - Method in interface org.ores.async.Asyncc.IAsyncCallback

Fire the continuation with either an error or a value (never both).

done(E, T) - Method in interface org.ores.async.NeoTimesI.ITimesCallback

done(Object, T) - Method in interface org.ores.async.NeoQueue.IAsyncErrFirstCb

Canonical error-first call: pass (null, value) on success or (err, null) on failure.

doneInternal(NeoWaterfallI.Marker, E, Map.Entry<String, T>) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

DoWhilst(NeoWhilstI.AsyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

DoWhilst(NeoWhilstI.SyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

DoWhilstLimit(int, NeoWhilstI.AsyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

DoWhilstLimit(int, NeoWhilstI.SyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

E

each(T, NeoEachI.IEachCallback<E>) - Method in interface org.ores.async.NeoEachI.IEacher

each(T, V, NeoEachI.IEachCallback<E>) - Method in interface org.ores.async.NeoEachI.IEacherWithTypedIndex

each(V, NeoEachI.IEachCallback<E>) - Method in class org.ores.async.NeoGeneric

Each(Iterable<T>, NeoEachI.IEacher<T, E>) - Static method in class org.ores.async.Asyncc

Each(Iterable<T>, NeoEachI.IEacher<T, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

Each(Map, NeoEachI.IEacher<T, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

Each(NeoEachI.AsyncValueMapTask<T, E>, Map<Object, Object>, NeoEachI.IEacher<T, E>) - Static method in class org.ores.async.Asyncc

Each(NeoEachI.AsyncValueTask<T, E>, List<T>, NeoEachI.IEacher<T, E>) - Static method in class org.ores.async.Asyncc

EachLimit(int, Iterable<T>, NeoEachI.IEacher<T, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachLimit(int, Map, NeoEachI.IEacher<T, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachOf(Iterable<T>, NeoEachI.IEacherWithTypedIndex<T, V, E>) - Static method in class org.ores.async.Asyncc

EachOf(Iterable<T>, NeoEachI.IEacherWithTypedIndex<T, V, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachOf(Map, NeoEachI.IEacherWithTypedIndex<T, V, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachOfLimit(int, Iterable<T>, NeoEachI.IEacherWithTypedIndex<T, V, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachOfLimit(int, Map, NeoEachI.IEacherWithTypedIndex<T, V, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachOfSeries(Iterable<T>, NeoEachI.IEacherWithTypedIndex<T, V, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachOfSeries(Map<Object, Object>, NeoEachI.IEacherWithTypedIndex<T, V, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachSeries(Iterable<T>, NeoEachI.IEacher<T, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

EachSeries(Map<Object, Object>, NeoEachI.IEacher<T, E>, NeoEachI.IEachCallback<E>) - Static method in class org.ores.async.Asyncc

F

fail(E) - Method in interface org.ores.async.Asyncc.IAsyncCallback

Fire the continuation with an error.

fail(E) - Method in interface org.ores.async.NeoWaterfallI.IAsyncCallback

Shorthand for done(e) — fail the Waterfall with the given error.

fail(Object) - Method in interface org.ores.async.NeoQueue.IAsyncErrFirstCb

Shorthand for done(e, null).

FilterMap(Iterable<T>, NeoFilterMapI.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

FilterMap(Iterable<T>, NeoFilterMapI.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

FilterMap(Map<Object, T>, NeoFilterMapI.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

FilterMap(Map<Object, T>, NeoFilterMapI.IMapper<T, V, E>, Asyncc.IAsyncCallback<Map<Object, V>, E>) - Static method in class org.ores.async.Asyncc

FilterMapLimit(Integer, Iterable<T>, NeoFilterMapI.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

FilterMapLimit(Integer, Iterable<T>, NeoFilterMapI.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

FilterMapLimit(Integer, Map<Object, T>, NeoFilterMapI.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

FilterMapLimit(Integer, Map<Object, T>, NeoFilterMapI.IMapper<T, V, E>, Asyncc.IAsyncCallback<Map<Object, V>, E>) - Static method in class org.ores.async.Asyncc

FilterMapSeries(Iterable<T>, NeoFilterMapI.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

FilterMapSeries(Iterable<T>, NeoFilterMapI.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

FilterMapSeries(Map<Object, T>, NeoFilterMapI.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

FilterMapSeries(Map<Object, T>, NeoFilterMapI.IMapper<T, V, E>, Asyncc.IAsyncCallback<Map<Object, V>, E>) - Static method in class org.ores.async.Asyncc

FlatMap - Class in org.ores.async

FlatMap() - Constructor for class org.ores.async.FlatMap

G

GENERIC - Enum constant in enum class org.ores.async.Asyncc.Overloader

get(String) - Method in class org.ores.async.NeoInjectI.AsyncCallbackSet

get(String) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

getConcurrency() - Method in class org.ores.async.NeoQueue

getNamespace() - Method in class org.ores.async.NeoLock

getNamespace() - Method in class org.ores.async.NeoRwLock

getOnDrainCbs() - Method in class org.ores.async.NeoQueue

getOnSaturatedCbs() - Method in class org.ores.async.NeoQueue

getOnUnsaturatedCbs() - Method in class org.ores.async.NeoQueue

getValue() - Method in class org.ores.async.NeoQueue.Task

GroupBy(Iterable<T>, NeoGroupByI.IMapper<T, E>, Asyncc.IAsyncCallback<Map<String, List<V>>, E>) - Static method in class org.ores.async.Asyncc

GroupByLimit(int, Iterable<T>, NeoGroupByI.IMapper<T, E>, Asyncc.IAsyncCallback<Map<String, List<V>>, E>) - Static method in class org.ores.async.Asyncc

GroupBySeries(Iterable<T>, NeoGroupByI.IMapper<T, E>, Asyncc.IAsyncCallback<Map<String, List<V>>, E>) - Static method in class org.ores.async.Asyncc

GroupToSets(Iterable<T>, NeoGroupByI.IMapper<T, E>, Asyncc.IAsyncCallback<Map<String, Set<V>>, E>) - Static method in class org.ores.async.Asyncc

GroupToSetsLimit(int, Iterable<T>, NeoGroupByI.IMapper<T, E>, Asyncc.IAsyncCallback<Map<String, Set<V>>, E>) - Static method in class org.ores.async.Asyncc

GroupToSetsSeries(Iterable<T>, NeoGroupByI.IMapper<T, E>, Asyncc.IAsyncCallback<Map<String, Set<V>>, E>) - Static method in class org.ores.async.Asyncc

I

include() - Method in class org.ores.async.NeoFilterI.AsyncCallback

include() - Method in class org.ores.async.NeoFilterMapI.AsyncCallback

Inject(Map.Entry<String, NeoInject.Task<T, E>>, Asyncc.IAsyncCallback<Map<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Inject(Map<String, NeoInject.Task<T, E>>) - Static method in class org.ores.async.Asyncc

Inject(Map<String, NeoInject.Task<T, E>>, Asyncc.IAsyncCallback<Map<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Inject(Map<String, NeoInject.Task<T, E>>, NeoInjectI.AsyncCallbackSet<Map, E>) - Static method in class org.ores.async.Asyncc

Inject(NeoInjectI.ValueTask<T, E>, Map<String, NeoInject.Task<T, E>>) - Static method in class org.ores.async.Asyncc

isDone - Static variable in interface org.ores.async.Asyncc.IAsyncCallback

isDrained() - Method in class org.ores.async.NeoQueue

isFinished - Variable in class org.ores.async.Asyncc.AsyncCallback

isIncluded() - Method in class org.ores.async.NeoFilterI.AsyncCallback

isIncluded() - Method in class org.ores.async.NeoFilterMapI.AsyncCallback

isLocked() - Method in class org.ores.async.NeoLock

Snapshot of whether the lock is currently held.

isShortCircuited() - Method in class org.ores.async.Asyncc.AsyncCallback

isShortCircuited() - Method in class org.ores.async.NeoQueue.AsyncCallback

isShortCircuited() - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

isStarted() - Method in class org.ores.async.NeoQueue.Task

isWriteHeld() - Method in class org.ores.async.NeoRwLock

Snapshot of whether a write lock is currently held.

K

keep - Variable in class org.ores.async.NeoRaceIfc.RaceParam

keep(boolean) - Method in class org.ores.async.NeoFilterI.AsyncCallback

keep(boolean) - Method in class org.ores.async.NeoFilterMapI.AsyncCallback

key - Variable in class org.ores.async.Asyncc.KeyValue

KeyValue(Map.Entry<K, V>) - Constructor for class org.ores.async.Asyncc.KeyValue

KeyValue(K, V) - Constructor for class org.ores.async.Asyncc.KeyValue

M

makeUnlock(boolean) - Method in class org.ores.async.NeoLock

map - Variable in class org.ores.async.NeoWaterfallI.AsyncCallback

map(T, Asyncc.IAsyncCallback<String, E>) - Method in interface org.ores.async.NeoGroupByI.IMapper

map(T, Asyncc.IAsyncCallback<V, E>) - Method in interface org.ores.async.Asyncc.IMapper

map(T, Asyncc.IAsyncCallback<V, E>) - Method in class org.ores.async.NeoGeneric

map(T, NeoFilterI.AsyncCallback<V, E>) - Method in interface org.ores.async.NeoFilterI.IMapper

map(T, NeoFilterMapI.AsyncCallback<V, E>) - Method in interface org.ores.async.NeoFilterMapI.IMapper

map(T, NeoRaceIfc.RaceCallback<V, E>) - Method in interface org.ores.async.NeoRaceIfc.IMapper

Map(Integer, List<T>, Asyncc.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

Map(Iterable<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

Map(List<T>, Asyncc.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

Map(Map<Object, T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<Map<Object, V>, E>) - Static method in class org.ores.async.Asyncc

Map(NeoEachI.AsyncValueTask<T, E>, Iterable<T>, Asyncc.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

MapLimit(Integer, Iterable<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

MapLimit(Integer, Map<Object, T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<Map<Object, V>, E>) - Static method in class org.ores.async.Asyncc

MapSeries(Iterable<T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<List<V>, E>) - Static method in class org.ores.async.Asyncc

MapSeries(List<T>, Asyncc.IMapper<T, V, E>) - Static method in class org.ores.async.Asyncc

MapSeries(Map<Object, T>, Asyncc.IMapper<T, V, E>, Asyncc.IAsyncCallback<Map<Object, V>, E>) - Static method in class org.ores.async.Asyncc

N

NeoEachI - Class in org.ores.async

NeoEachI() - Constructor for class org.ores.async.NeoEachI

NeoEachI.AsyncEachTask<E> - Interface in org.ores.async

NeoEachI.AsyncValueMapTask<T,E> - Interface in org.ores.async

NeoEachI.AsyncValueTask<T,E> - Interface in org.ores.async

NeoEachI.EachCallback<E> - Class in org.ores.async

NeoEachI.IEachCallback<E> - Interface in org.ores.async

NeoEachI.IEachCallbacks<E> - Interface in org.ores.async

NeoEachI.IEacher<T,E> - Interface in org.ores.async

NeoEachI.IEacherWithTypedIndex<T,V,E> - Interface in org.ores.async

NeoFilter - Class in org.ores.async

NeoFilter() - Constructor for class org.ores.async.NeoFilter

NeoFilterI - Class in org.ores.async

NeoFilterI() - Constructor for class org.ores.async.NeoFilterI

NeoFilterI.AsyncCallback<T,E> - Class in org.ores.async

NeoFilterI.IMapper<T,V,E> - Interface in org.ores.async

NeoFilterMap - Class in org.ores.async

NeoFilterMap() - Constructor for class org.ores.async.NeoFilterMap

NeoFilterMapI - Class in org.ores.async

NeoFilterMapI() - Constructor for class org.ores.async.NeoFilterMapI

NeoFilterMapI.AsyncCallback<T,E> - Class in org.ores.async

NeoFilterMapI.IMapper<T,V,E> - Interface in org.ores.async

NeoGeneric<T,V,E> - Class in org.ores.async

NeoGeneric() - Constructor for class org.ores.async.NeoGeneric

NeoGroupBy - Class in org.ores.async

NeoGroupBy() - Constructor for class org.ores.async.NeoGroupBy

NeoGroupByI - Class in org.ores.async

NeoGroupByI() - Constructor for class org.ores.async.NeoGroupByI

NeoGroupByI.AsyncCallback<T,E> - Class in org.ores.async

NeoGroupByI.IMapper<T,E> - Interface in org.ores.async

NeoInject - Class in org.ores.async

NeoInject() - Constructor for class org.ores.async.NeoInject

NeoInject.Task<T,E> - Class in org.ores.async

new BeanTranslator.Builder() .translate( newTranslator<String, Integer>(String.class, Integer.class){ @Override public Integer translate(String instance) { return Integer.valueOf(instance); }}) .build();

NeoInjectI - Class in org.ores.async

NeoInjectI() - Constructor for class org.ores.async.NeoInjectI

NeoInjectI.AsyncCallbackSet<T,E> - Class in org.ores.async

NeoInjectI.IInjectable<T,E> - Interface in org.ores.async

NeoInjectI.ValueTask<T,E> - Interface in org.ores.async

NeoLock - Class in org.ores.async

An async (non-blocking) mutex.

NeoLock() - Constructor for class org.ores.async.NeoLock

NeoLock(String) - Constructor for class org.ores.async.NeoLock

NeoMapI - Class in org.ores.async

NeoMapI() - Constructor for class org.ores.async.NeoMapI

NeoMapI.AsyncCallback<T,E> - Class in org.ores.async

NeoQueue<T,V> - Class in org.ores.async

A bounded async work queue.

NeoQueue(Integer, NeoQueue.ITaskHandler<T, V>) - Constructor for class org.ores.async.NeoQueue

NeoQueue(NeoQueue.ITaskHandler<T, V>) - Constructor for class org.ores.async.NeoQueue

NeoQueue.AsyncCallback<T> - Class in org.ores.async

NeoQueue.IAsyncCb - Interface in org.ores.async

NeoQueue.IAsyncErrFirstCb<T> - Interface in org.ores.async

Error-first continuation used by NeoQueue.ITaskHandler.

NeoQueue.ICallbacks<T> - Interface in org.ores.async

NeoQueue.ITaskHandler<T,V> - Interface in org.ores.async

NeoQueue.Task<T,V> - Class in org.ores.async

NeoRaceIfc - Class in org.ores.async

NeoRaceIfc() - Constructor for class org.ores.async.NeoRaceIfc

NeoRaceIfc.AsyncTask<T,E> - Interface in org.ores.async

NeoRaceIfc.IMapper<T,V,E> - Interface in org.ores.async

NeoRaceIfc.RaceCallback<T,E> - Class in org.ores.async

NeoRaceIfc.RaceParam<T> - Class in org.ores.async

NeoReduceI - Class in org.ores.async

NeoReduceI() - Constructor for class org.ores.async.NeoReduceI

NeoReduceI.IReducer<T,V,E> - Interface in org.ores.async

NeoReduceI.ReduceArg<T,V> - Class in org.ores.async

NeoRwLock - Class in org.ores.async

An async (non-blocking) reader/writer lock.

NeoRwLock() - Constructor for class org.ores.async.NeoRwLock

NeoRwLock(String) - Constructor for class org.ores.async.NeoRwLock

NeoTimesI - Class in org.ores.async

NeoTimesI() - Constructor for class org.ores.async.NeoTimesI

NeoTimesI.AsyncTimesTask<T,E> - Interface in org.ores.async

NeoTimesI.AsyncValueMapTask<T,E> - Interface in org.ores.async

NeoTimesI.AsyncValueTask<T,E> - Interface in org.ores.async

NeoTimesI.ITimesCallback<T,E> - Interface in org.ores.async

NeoTimesI.ITimesCallbacks<T,E> - Interface in org.ores.async

NeoTimesI.ITimesr<T,E> - Interface in org.ores.async

NeoWaterfallI - Class in org.ores.async

NeoWaterfallI() - Constructor for class org.ores.async.NeoWaterfallI

NeoWaterfallI.AsyncCallback<T,E> - Class in org.ores.async

NeoWaterfallI.AsyncTask<T,E> - Interface in org.ores.async

NeoWaterfallI.AsyncValueTask<T,E> - Interface in org.ores.async

NeoWaterfallI.IAsyncCallback<T,E> - Interface in org.ores.async

NeoWaterfallI.ICallbacks<T,E> - Interface in org.ores.async

NeoWhilst - Class in org.ores.async

NeoWhilst() - Constructor for class org.ores.async.NeoWhilst

NeoWhilstI - Class in org.ores.async

NeoWhilstI() - Constructor for class org.ores.async.NeoWhilstI

NeoWhilstI.AsyncCallback<T,E> - Class in org.ores.async

NeoWhilstI.AsyncTask<T,E> - Interface in org.ores.async

NeoWhilstI.AsyncTruthTest - Interface in org.ores.async

NeoWhilstI.SyncTruthTest - Interface in org.ores.async

nudge() - Method in class org.ores.async.NeoQueue

O

onDrain(NeoQueue.IAsyncCb) - Method in class org.ores.async.NeoQueue

onSaturated(NeoQueue.IAsyncCb) - Method in class org.ores.async.NeoQueue

onUnsaturated(NeoQueue.IAsyncCb) - Method in class org.ores.async.NeoQueue

org.ores.async - package org.ores.async

async.java — callback-based async control flow for the JVM

P

Parallel(List<Asyncc.AsyncTask<T, E>>) - Static method in class org.ores.async.Asyncc

Parallel(List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map.Entry<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Map<Object, Asyncc.AsyncTask<T, E>>) - Static method in class org.ores.async.Asyncc

Parallel(Map<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>...) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Parallel(NeoParallelI.AsyncValueTask<T, E>, Asyncc.AsyncTask<T, E>...) - Static method in class org.ores.async.Asyncc

ParallelLimit(int, List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

public class JavadocTest { // indentation and line breaks are kept

ParallelLimit(int, Map<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

pause() - Method in class org.ores.async.NeoQueue

prev - Variable in class org.ores.async.NeoReduceI.ReduceArg

push(NeoQueue.Task<T, V>) - Method in class org.ores.async.NeoQueue

push(NeoQueue.Task<T, V>, NeoQueue.IAsyncErrFirstCb<V>) - Method in class org.ores.async.NeoQueue

Q

queueDepth() - Method in class org.ores.async.NeoLock

Snapshot of the number of waiters currently queued behind the holder.

queueDepth() - Method in class org.ores.async.NeoRwLock

Snapshot of the number of waiters queued behind the current holder(s).

R

Race(Iterable<NeoRaceIfc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

Race(Iterable<T>, NeoRaceIfc.IMapper<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

Race(Map<Object, NeoRaceIfc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

Race(Map<Object, T>, NeoRaceIfc.IMapper<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

RaceCallback(ShortCircuit) - Constructor for class org.ores.async.NeoRaceIfc.RaceCallback

RaceLimit(Integer, Iterable<NeoRaceIfc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

RaceLimit(Integer, Iterable<T>, NeoRaceIfc.IMapper<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

RaceLimit(Integer, Map<Object, NeoRaceIfc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

RaceLimit(Integer, Map<Object, T>, NeoRaceIfc.IMapper<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

RaceParam(Boolean, T) - Constructor for class org.ores.async.NeoRaceIfc.RaceParam

RaceParam(T) - Constructor for class org.ores.async.NeoRaceIfc.RaceParam

readerCount() - Method in class org.ores.async.NeoRwLock

Snapshot of the number of currently-held read locks.

reduce(V, T, Asyncc.IAsyncCallback<V, E>) - Method in class org.ores.async.NeoGeneric

reduce(V, T, Asyncc.IAsyncCallback<V, E>) - Method in interface org.ores.async.NeoReduceI.IReducer

Reduce(I, List<T>, NeoReduceI.IReducer<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

Reduce(List<T>, NeoReduceI.IReducer<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

ReduceArg(V, T) - Constructor for class org.ores.async.NeoReduceI.ReduceArg

ReduceRight(I, List<T>, NeoReduceI.IReducer<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

ReduceRight(List<T>, NeoReduceI.IReducer<T, V, E>, Asyncc.IAsyncCallback<V, E>) - Static method in class org.ores.async.Asyncc

reject(E) - Method in class org.ores.async.Asyncc.AsyncCallback

reject(E) - Method in interface org.ores.async.Asyncc.ICallbacks

reject(E) - Method in interface org.ores.async.NeoEachI.IEachCallbacks

reject(E) - Method in interface org.ores.async.NeoTimesI.ITimesCallbacks

reject(E) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

reject(E) - Method in interface org.ores.async.NeoWaterfallI.ICallbacks

reject(Object) - Method in interface org.ores.async.NeoQueue.ICallbacks

releaseLock() - Method in class org.ores.async.Unlock

resolve() - Method in class org.ores.async.NeoEachI.EachCallback

resolve() - Method in interface org.ores.async.NeoEachI.IEachCallbacks

resolve(String, T) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

resolve(String, T) - Method in interface org.ores.async.NeoWaterfallI.ICallbacks

resolve(Map.Entry<String, T>) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

resolve(Map.Entry<String, T>) - Method in interface org.ores.async.NeoWaterfallI.ICallbacks

resolve(T) - Method in class org.ores.async.Asyncc.AsyncCallback

resolve(T) - Method in interface org.ores.async.Asyncc.ICallbacks

resolve(T) - Method in interface org.ores.async.NeoQueue.ICallbacks

resolve(T) - Method in interface org.ores.async.NeoTimesI.ITimesCallbacks

resume() - Method in class org.ores.async.NeoQueue

run(Integer, NeoTimesI.ITimesCallback<T, E>) - Method in interface org.ores.async.NeoTimesI.ITimesr

run(Object) - Method in interface org.ores.async.NeoInjectI.ValueTask

run(Object, List<T>, NeoEachI.IEachCallback<E>) - Method in interface org.ores.async.NeoEachI.AsyncValueTask

run(Object, Map<Object, Object>, NeoEachI.IEachCallback<E>) - Method in interface org.ores.async.NeoEachI.AsyncValueMapTask

run(Object, Map<Object, Object>, NeoTimesI.ITimesCallback<T, E>) - Method in interface org.ores.async.NeoTimesI.AsyncValueMapTask

run(Object, Asyncc.IAsyncCallback<T, E>) - Method in interface org.ores.async.Asyncc.AsyncValueTask

run(Object, Asyncc.IAsyncCallback<V, E>) - Method in class org.ores.async.NeoGeneric

run(Object, NeoTimesI.ITimesCallback<T, E>) - Method in interface org.ores.async.NeoTimesI.AsyncValueTask

run(Object, NeoWaterfallI.AsyncCallback<T, E>) - Method in interface org.ores.async.NeoWaterfallI.AsyncValueTask

run(Object, NeoWaterfallI.AsyncCallback<V, E>) - Method in class org.ores.async.NeoGeneric

run(Asyncc.IAsyncCallback<T, E>) - Method in interface org.ores.async.Asyncc.AsyncTask

run(NeoEachI.IEachCallback<E>) - Method in interface org.ores.async.NeoEachI.AsyncEachTask

run(NeoInjectI.AsyncCallbackSet<T, E>) - Method in interface org.ores.async.NeoInjectI.IInjectable

run(NeoQueue) - Method in interface org.ores.async.NeoQueue.IAsyncCb

run(NeoQueue.Task<T, V>, NeoQueue.IAsyncErrFirstCb<V>) - Method in interface org.ores.async.NeoQueue.ITaskHandler

run(NeoRaceIfc.RaceCallback<T, E>) - Method in interface org.ores.async.NeoRaceIfc.AsyncTask

run(NeoTimesI.ITimesCallback<T, E>) - Method in interface org.ores.async.NeoTimesI.AsyncTimesTask

run(NeoWaterfallI.AsyncCallback<T, E>) - Method in interface org.ores.async.NeoWaterfallI.AsyncTask

run(NeoWhilstI.AsyncCallback<T, E>) - Method in interface org.ores.async.NeoWhilstI.AsyncTask

S

s - Variable in class org.ores.async.Asyncc.AsyncCallback

Series(int, NeoTimesI.ITimesr<T, E>, NeoTimesI.ITimesCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(List<Asyncc.AsyncTask<T, E>>) - Static method in class org.ores.async.Asyncc

Series(List<Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Map<Object, Asyncc.AsyncTask<T, E>>) - Static method in class org.ores.async.Asyncc

Series(Map<Object, Asyncc.AsyncTask<T, E>>, Asyncc.IAsyncCallback<Map<Object, T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>...) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Series(Asyncc.AsyncValueTask<T, E>, Asyncc.AsyncTask<T, E>...) - Static method in class org.ores.async.Asyncc

set(String, V) - Method in class org.ores.async.NeoWaterfallI.AsyncCallback

setConcurrency(Integer) - Method in class org.ores.async.NeoQueue

setDone() - Method in interface org.ores.async.Asyncc.IAsyncCallback

setDrained(boolean) - Method in class org.ores.async.NeoQueue

setExecutor(ExecutorService) - Static method in class org.ores.async.NeoQueue

Swap the shared executor used for callback delivery.

setOnNext(Asyncc.IAcceptRunnable) - Static method in class org.ores.async.Asyncc

setValue(boolean, T) - Method in class org.ores.async.NeoRaceIfc.RaceCallback

setValue(T) - Method in class org.ores.async.NeoRaceIfc.RaceCallback

shutdown() - Static method in class org.ores.async.NeoQueue

Shut down the default executor.

success(String, T) - Method in interface org.ores.async.NeoWaterfallI.IAsyncCallback

Shorthand for done(null, k, v) — name the value going into the next Waterfall stage.

success(T) - Method in interface org.ores.async.Asyncc.IAsyncCallback

Fire the continuation with a successful value.

success(T) - Method in interface org.ores.async.NeoQueue.IAsyncErrFirstCb

Shorthand for done(null, v).

sync - Static variable in class org.ores.async.Asyncc

T

Task(String, String, String, String, String, String, String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(String, String, String, String, String, String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(String, String, String, String, String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(String, String, String, String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(String, String, String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(String, String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(String, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(Set<String>, NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(NeoInjectI.IInjectable<T, E>) - Constructor for class org.ores.async.NeoInject.Task

Task(T) - Constructor for class org.ores.async.NeoQueue.Task

Task(T, NeoQueue.IAsyncErrFirstCb<V>) - Constructor for class org.ores.async.NeoQueue.Task

test() - Method in interface org.ores.async.NeoWhilstI.SyncTruthTest

test(Asyncc.IAsyncCallback<Boolean, Object>) - Method in interface org.ores.async.NeoWhilstI.AsyncTruthTest

Times(int, NeoTimesI.ITimesr<T, E>, NeoTimesI.ITimesCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

TimesLimit(int, int, NeoTimesI.ITimesr<T, E>, NeoTimesI.ITimesCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

tryAcquire() - Method in class org.ores.async.NeoLock

Non-blocking attempt to acquire the lock.

tryAcquireRead() - Method in class org.ores.async.NeoRwLock

Non-blocking attempt to acquire a read lock.

tryAcquireWrite() - Method in class org.ores.async.NeoRwLock

Non-blocking attempt to acquire a write lock.

U

Unlock - Class in org.ores.async

Token returned to a acquire callback.

Unlock(boolean) - Constructor for class org.ores.async.Unlock

unshift(NeoQueue.Task<T, V>) - Method in class org.ores.async.NeoQueue

V

value - Variable in class org.ores.async.Asyncc.KeyValue

value - Variable in class org.ores.async.NeoRaceIfc.RaceParam

valueOf(String) - Static method in enum class org.ores.async.Asyncc.Overloader

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.ores.async.Asyncc.Overloader

Returns an array containing the constants of this enum class, in the order they are declared.

W

Waterfall(List<NeoWaterfallI.AsyncTask<T, E>>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncTask<T, E>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, NeoWaterfallI.AsyncTask<T, E>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Waterfall(NeoWaterfallI.AsyncValueTask<T, E>, NeoWaterfallI.AsyncTask<T, E>...) - Static method in class org.ores.async.Asyncc

Waterfall2(List<NeoWaterfallI.AsyncTask<T, E>>, Asyncc.IAsyncCallback<HashMap<String, Object>, E>) - Static method in class org.ores.async.Asyncc

Whilst(NeoWhilstI.AsyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

Whilst(NeoWhilstI.SyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

WhilstLimit(int, NeoWhilstI.AsyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

WhilstLimit(int, NeoWhilstI.SyncTruthTest, NeoWhilstI.AsyncTask<T, E>, Asyncc.IAsyncCallback<List<T>, E>) - Static method in class org.ores.async.Asyncc

withLock(Runnable) - Method in class org.ores.async.NeoLock

Acquire the lock, run the criticalSection synchronously, release.

withRead(Runnable) - Method in class org.ores.async.NeoRwLock

Acquire a read lock, run the (synchronous) criticalSection, release.

withWrite(Runnable) - Method in class org.ores.async.NeoRwLock

Acquire a write lock, run the (synchronous) criticalSection, release.

wrap(Consumer<V>) - Static method in class org.ores.async.WrapErrFirst

Wrap a value-only consumer into an error-first Asyncc.IAsyncCallback.

wrap(Consumer<V>, Consumer<E>) - Static method in class org.ores.async.WrapErrFirst

Wrap two value-only consumers into an error-first Asyncc.IAsyncCallback.

WrapErrFirst - Class in org.ores.async

Helpers that adapt error-first callbacks into more concise call sites.

A C D E F G I K M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values