| 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. |