Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
BufferedPushStreamImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
(package private) class |
IntermediatePushStreamImpl<T> |
(package private) class |
UnbufferedPushStreamImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
Modifier and Type | Field and Description |
---|---|
private AbstractPushStreamImpl<?> |
IntermediatePushStreamImpl.previous |
Modifier and Type | Method and Description |
---|---|
private <R> void |
AbstractPushStreamImpl.aggregateAndForward(java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f,
AbstractPushStreamImpl<R> eventStream,
PushEvent<? extends T> event,
java.util.Queue<T> queue,
java.util.concurrent.Executor executor,
long elapsed) |
private <R> long |
AbstractPushStreamImpl.aggregateAndForward(Function<java.util.Collection<T>,R> f,
AbstractPushStreamImpl<R> eventStream,
PushEvent<? extends T> event,
java.util.Queue<T> queue) |
private <R> java.lang.Runnable |
AbstractPushStreamImpl.getWindowTask(AbstractPushStreamImpl<R> eventStream,
java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f,
java.util.function.Supplier<java.time.Duration> time,
java.util.function.IntSupplier maxEvents,
java.lang.Object lock,
long expectedCounter,
java.util.concurrent.atomic.AtomicReference<java.util.Queue<T>> queueRef,
java.util.concurrent.atomic.AtomicLong timestamp,
java.util.concurrent.atomic.AtomicLong counter,
java.util.concurrent.atomic.AtomicLong previousWindowSize,
java.util.concurrent.Executor executor) |
Constructor and Description |
---|
IntermediatePushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
AbstractPushStreamImpl<?> previous) |