Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Class and Description |
---|---|
private static class |
PushStreamProvider.MultiplexingConsumer<T> |
(package private) static class |
PushStreamProvider.PushEventPipe<T> |
Modifier and Type | Field and Description |
---|---|
(package private) PushEventConsumer<? super T> |
PushStreamProvider.PushEventPipe.delegate |
Modifier and Type | Field and Description |
---|---|
private java.util.List<PushEventConsumer<? super T>> |
SimplePushEventSourceImpl.connected |
protected java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> |
UnbufferedPushStreamImpl.connector |
private java.util.concurrent.CopyOnWriteArrayList<PushEventConsumer<? super T>> |
PushStreamProvider.MultiplexingConsumer.consumers |
protected java.util.concurrent.atomic.AtomicReference<PushEventConsumer<T>> |
AbstractPushStreamImpl.next |
Modifier and Type | Method and Description |
---|---|
<T> PushEventConsumer<T> |
PushStreamProvider.createBufferedConsumer(PushEventConsumer<T> delegate)
Create a buffered
PushEventConsumer with the default configured
buffer, executor size, queue, queue policy and pushback policy. |
Modifier and Type | Method and Description |
---|---|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate)
Build a buffered
PushEventConsumer with custom configuration. |
Modifier and Type | Method and Description |
---|---|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate)
Build a buffered
PushEventConsumer with custom configuration. |
private void |
SimplePushEventSourceImpl.closeConsumer(PushEventConsumer<? super T> pec,
PushEvent<T> event) |
<T> PushEventConsumer<T> |
PushStreamProvider.createBufferedConsumer(PushEventConsumer<T> delegate)
Create a buffered
PushEventConsumer with the default configured
buffer, executor size, queue, queue policy and pushback policy. |
private Promise<java.lang.Long> |
SimplePushEventSourceImpl.doCall(PushEvent<T> event,
PushEventConsumer<? super T> pec) |
private void |
SimplePushEventSourceImpl.doSend(PushEventConsumer<? super T> pec,
PushEvent<T> event) |
private Promise<java.lang.Long> |
SimplePushEventSourceImpl.doSendWithBackPressure(PushEventConsumer<? super T> pec,
PushEvent<T> event) |
Promise<java.lang.Long> |
PushStream.forEachEvent(PushEventConsumer<? super T> action)
Pass on each event to another consumer until the stream is closed.
|
Promise<java.lang.Long> |
AbstractPushStreamImpl.forEachEvent(PushEventConsumer<? super T> action) |
java.lang.AutoCloseable |
SimplePushEventSourceImpl.open(PushEventConsumer<? super T> pec) |
java.lang.AutoCloseable |
PushStreamProvider.PushEventPipe.open(PushEventConsumer<? super T> pec) |
java.lang.AutoCloseable |
PushEventSource.open(PushEventConsumer<? super T> aec)
Open the asynchronous channel between the source and the consumer.
|
private long |
SimplePushEventSourceImpl.safePush(PushEventConsumer<? super T> pec,
PushEvent<T> event) |
private void |
AbstractPushStreamImpl.updateNext(PushEventConsumer<T> consumer) |
Modifier and Type | Method and Description |
---|---|
private Promise<java.lang.Long> |
SimplePushEventSourceImpl.deliver(java.util.List<PushEventConsumer<? super T>> toCall,
PushEvent<T> event) |
Constructor and Description |
---|
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) |
MultiplexingConsumer(java.util.concurrent.atomic.AtomicReference<PushEvent<T>> terminalEventStore,
java.util.concurrent.CopyOnWriteArrayList<PushEventConsumer<? super T>> consumers) |
UnbufferedPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector) |