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 BlockingQueue<PushEvent<? extends T>>>
(package private) class	IntermediatePushStreamImpl<T>
(package private) class	UnbufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>

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

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

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

Modifier and Type	Method	Description
private <R> void	AbstractPushStreamImpl.aggregateAndForward(BiFunction<Long,Collection<T>,R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue, Executor executor, long elapsed)
private <R> long	AbstractPushStreamImpl.aggregateAndForward(Function<Collection<T>,R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue)
private <R> Runnable	AbstractPushStreamImpl.getWindowTask(AbstractPushStreamImpl<R> eventStream, BiFunction<Long,Collection<T>,R> f, Supplier<Duration> time, IntSupplier maxEvents, Object lock, long expectedCounter, AtomicReference<Queue<T>> queueRef, AtomicLong timestamp, AtomicLong counter, AtomicLong previousWindowSize, Executor executor)

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

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