Uses of Class
org.osgi.util.pushstream.AbstractPushStreamImpl
Packages that use AbstractPushStreamImpl
-
Uses of AbstractPushStreamImpl in org.osgi.util.pushstream
Subclasses of AbstractPushStreamImpl in org.osgi.util.pushstreamModifier and TypeClassDescription(package private) class
BufferedPushStreamImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> (package private) class
(package private) class
UnbufferedPushStreamImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> Fields in org.osgi.util.pushstream declared as AbstractPushStreamImplModifier and TypeFieldDescriptionprivate final AbstractPushStreamImpl<?>
IntermediatePushStreamImpl.previous
Methods in org.osgi.util.pushstream with parameters of type AbstractPushStreamImplModifier and TypeMethodDescriptionprivate <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 AbstractPushStreamImplModifierConstructorDescription(package private)
IntermediatePushStreamImpl
(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)