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)
-