Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SimplePushEventSource<T>
A
SimplePushEventSource is a helper that makes it simpler to write a
PushEventSource . |
Modifier and Type | Class and Description |
---|---|
(package private) static class |
PushStreamProvider.PushEventPipe<T> |
(package private) class |
SimplePushEventSourceImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
Modifier and Type | Field and Description |
---|---|
private PushEventSource<T> |
PushStreamBuilderImpl.eventSource |
Modifier and Type | Method and Description |
---|---|
<T> PushEventSource<T> |
PushStreamProvider.createEventSourceFromStream(PushStream<T> stream)
Convert an
PushStream into an PushEventSource . |
Modifier and Type | Method and Description |
---|---|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream)
Convert an
PushStream into an PushEventSource . |
Modifier and Type | Method and Description |
---|---|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildStream(PushEventSource<T> eventSource)
Builds a push stream with custom configuration.
|
<T> PushStream<T> |
PushStreamProvider.createStream(PushEventSource<T> eventSource)
Create a stream with the default configured buffer, executor size, queue,
queue policy and pushback policy.
|
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.createStream(PushEventSource<T> eventSource,
int parallelism,
java.util.concurrent.Executor executor,
java.util.concurrent.ScheduledExecutorService scheduler,
U queue,
QueuePolicy<T,U> queuePolicy,
PushbackPolicy<T,U> pushbackPolicy) |
(package private) <T> PushStream<T> |
PushStreamProvider.createUnbufferedStream(PushEventSource<T> eventSource,
java.util.concurrent.Executor executor,
java.util.concurrent.ScheduledExecutorService scheduler) |
PushStream<T> |
PushStream.merge(PushEventSource<? extends T> source)
Merge in the events from another source.
|
PushStream<T> |
AbstractPushStreamImpl.merge(PushEventSource<? extends T> source) |
Constructor and Description |
---|
PushStreamBuilderImpl(PushStreamProvider psp,
java.util.concurrent.Executor defaultExecutor,
java.util.concurrent.ScheduledExecutorService defaultScheduler,
PushEventSource<T> eventSource) |