Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
SimplePushEventSourceImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
Modifier and Type | Method and Description |
---|---|
<T> SimplePushEventSource<T> |
PushStreamProvider.createSimpleEventSource(java.lang.Class<T> type)
Create a
SimplePushEventSource with the supplied type and default
buffering behaviors. |
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.createSimplePushEventSource(int parallelism,
java.util.concurrent.Executor executor,
U queue,
QueuePolicy<T,U> queuePolicy,
java.lang.Runnable onClose) |
Modifier and Type | Method and Description |
---|---|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildSimpleEventSource(java.lang.Class<T> type)
Build a
SimplePushEventSource with the supplied type and custom
buffering behaviors. |