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 |
---|---|
protected PromiseFactory |
AbstractPushStreamImpl.promiseFactory |
private PromiseFactory |
SimplePushEventSourceImpl.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) |