Uses of Class
org.osgi.util.pushstream.AbstractPushStreamImpl

Packages that use AbstractPushStreamImpl

Package	Description
org.osgi.util.pushstream	Push Stream Package Version 1.0.

Uses of AbstractPushStreamImpl in org.osgi.util.pushstream

Subclasses of AbstractPushStreamImpl in org.osgi.util.pushstream

Modifier and Type	Class	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>>>

Fields in org.osgi.util.pushstream declared as AbstractPushStreamImpl

Modifier and Type	Field	Description
private AbstractPushStreamImpl<?>	IntermediatePushStreamImpl.previous

Methods in org.osgi.util.pushstream with parameters of type AbstractPushStreamImpl

Modifier and Type	Method	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)

Constructors in org.osgi.util.pushstream with parameters of type AbstractPushStreamImpl

Constructor	Description
IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)