| Package | Description |
|---|---|
| org.osgi.util.promise |
Promise Package Version 1.1.
|
| org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) static PromiseFactory |
PromiseFactory.defaultFactory
The default factory which uses the default callback executor and default
scheduled executor.
|
private PromiseFactory |
PromiseImpl.factory
The factory to use for callbacks and scheduled operations.
|
| Constructor and Description |
|---|
Deferred(PromiseFactory factory)
Create a new Deferred with the specified callback and scheduled
executors.
|
DeferredPromiseImpl(PromiseFactory factory)
Initialize this Promise.
|
FailedPromiseImpl(java.lang.Throwable fail,
PromiseFactory factory)
Initialize this failed Promise.
|
PromiseImpl(PromiseFactory factory)
Initialize this Promise.
|
ResolvedPromiseImpl(T value,
PromiseFactory factory)
Initialize this resolved Promise.
|
| Modifier and Type | Field and Description |
|---|---|
private PromiseFactory |
SimplePushEventSourceImpl.promiseFactory |
protected PromiseFactory |
AbstractPushStreamImpl.promiseFactory |
private PromiseFactory |
SimplePushEventSourceImpl.sameThread |
| Constructor and Description |
|---|
AbstractPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory) |
BufferedPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
U eventQueue,
int parallelism,
QueuePolicy<T,U> queuePolicy,
PushbackPolicy<T,U> pushbackPolicy,
java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector) |
IntermediatePushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
AbstractPushStreamImpl<?> previous) |
SimplePushEventSourceImpl(PromiseFactory promiseFactory,
QueuePolicy<T,U> queuePolicy,
U queue,
int parallelism,
java.lang.Runnable onClose) |
UnbufferedPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector) |