Uses of Interface
org.osgi.util.pushstream.PushStream
Packages that use PushStream
Package
Description
Log Stream Package Version 1.0.
Push Stream Package Version 1.0.
-
Uses of PushStream in org.osgi.service.log.stream
Methods in org.osgi.service.log.stream that return PushStreamModifier and TypeMethodDescriptionLogStreamProvider.createStream
(LogStreamProvider.Options... options) Create aPushStream
ofLogEntry
objects. -
Uses of PushStream in org.osgi.util.pushstream
Classes in org.osgi.util.pushstream that implement PushStreamModifier and TypeClassDescription(package private) class
(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>>> Methods in org.osgi.util.pushstream that return PushStreamModifier and TypeMethodDescriptionAbstractPushStreamImpl.adjustBackPressure
(LongUnaryOperator adjustment) AbstractPushStreamImpl.adjustBackPressure
(ToLongBiFunction<T, Long> adjustment) PushStream.adjustBackPressure
(LongUnaryOperator adjustment) Changes the back-pressure propagated by this pipeline stage.PushStream.adjustBackPressure
(ToLongBiFunction<T, Long> adjustment) Changes the back-pressure propagated by this pipeline stage.<R> PushStream
<R> <R> PushStream
<R> Asynchronously map the payload values.AbstractPushStreamImpl.buffer()
PushStream.buffer()
Buffer the events in a queue using default values for the queue size and other behaviors.PushStreamBuilderImpl.build()
private <T> PushStream
<T> PushStreamProvider.cleanupThreads
(boolean closeExecutorOnClose, Executor workerToUse, boolean releaseSchedulerOnClose, PushStream<T> stream) <R> PushStream
<R> AbstractPushStreamImpl.coalesce
(int count, Function<Collection<T>, R> f) <R> PushStream
<R> AbstractPushStreamImpl.coalesce
(IntSupplier count, Function<Collection<T>, R> f) <R> PushStream
<R> <R> PushStream
<R> PushStream.coalesce
(int count, Function<Collection<T>, R> f) Coalesces a number of events into a new type of event.<R> PushStream
<R> PushStream.coalesce
(IntSupplier count, Function<Collection<T>, R> f) Coalesces a number of events into a new type of event.<R> PushStream
<R> Coalesces a number of events into a new type of event.<T> PushStream
<T> PushStreamProvider.createStream
(PushEventSource<T> eventSource) Create a stream with the default configured buffer, executor size, queue, queue policy and pushback policy.(package private) <T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushStream<T> PushStreamProvider.createStream
(PushEventSource<T> eventSource, int parallelism, Executor executor, ScheduledExecutorService scheduler, U queue, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy) (package private) <T> PushStream
<T> PushStreamProvider.createUnbufferedStream
(PushEventSource<T> eventSource, Executor executor, ScheduledExecutorService scheduler) AbstractPushStreamImpl.distinct()
PushStream.distinct()
Remove any duplicates.Only pass events downstream when the predicate tests true.<R> PushStream
<R> AbstractPushStreamImpl.flatMap
(Function<? super T, ? extends PushStream<? extends R>> mapper) <R> PushStream
<R> PushStream.flatMap
(Function<? super T, ? extends PushStream<? extends R>> mapper) Flat map the payload value (turn one event into 0..n events of potentially another type).Execute the downstream events in up to n background threads.AbstractPushStreamImpl.limit
(long maxSize) PushStream.limit
(long maxSize) Automatically close the channel after the maxSize number of elements is received.Automatically close the channel after the given amount of time has elapsed.<R> PushStream
<R> <R> PushStream
<R> Map a payload value.AbstractPushStreamImpl.merge
(PushEventSource<? extends T> source) AbstractPushStreamImpl.merge
(PushStream<? extends T> source) PushStream.merge
(PushEventSource<? extends T> source) Merge in the events from another source.PushStream.merge
(PushStream<? extends T> source) Merge in the events from another PushStream.Must be run after the channel is closed.Must be run after the channel is closed.AbstractPushStreamImpl.sequential()
PushStream.sequential()
Ensure that any events are delivered sequentially.AbstractPushStreamImpl.skip
(long n) PushStream.skip
(long n) Skip a number of events in the channel.AbstractPushStreamImpl.sorted()
AbstractPushStreamImpl.sorted
(Comparator<? super T> comparator) PushStream.sorted()
Sorted the elements, assuming that T extends Comparable.PushStream.sorted
(Comparator<? super T> comparator) Sorted the elements with the given comparator.PushStream<T>[]
PushStream<T>[]
Split the events to different streams based on a predicate.<T> PushStream
<T> PushStreamProvider.streamOf
(Executor executor, ScheduledExecutorService scheduler, Stream<T> items) Create an UnbufferedPushStream
from a JavaStream
The data from the stream will be pushed into the PushStream asynchronously using the supplied Executor.<T> PushStream
<T> Create an UnbufferedPushStream
from a JavaStream
The data from the stream will be pushed into the PushStream synchronously as it is opened.Automatically fail the channel if no events are received for the indicated length of time.<R> PushStream
<R> <R> PushStream
<R> AbstractPushStreamImpl.window
(Duration time, Function<Collection<T>, R> f) <R> PushStream
<R> AbstractPushStreamImpl.window
(Supplier<Duration> time, IntSupplier maxEvents, Executor ex, BiFunction<Long, Collection<T>, R> f) <R> PushStream
<R> AbstractPushStreamImpl.window
(Supplier<Duration> time, IntSupplier maxEvents, BiFunction<Long, Collection<T>, R> f) <R> PushStream
<R> Buffers a number of events over a fixed time interval and then forwards the events to an accumulator function.<R> PushStream
<R> PushStream.window
(Duration d, Function<Collection<T>, R> f) Buffers a number of events over a fixed time interval and then forwards the events to an accumulator function.<R> PushStream
<R> PushStream.window
(Supplier<Duration> timeSupplier, IntSupplier maxEvents, Executor executor, BiFunction<Long, Collection<T>, R> f) Buffers a number of events over a variable time interval and then forwards the events to an accumulator function.<R> PushStream
<R> PushStream.window
(Supplier<Duration> timeSupplier, IntSupplier maxEvents, BiFunction<Long, Collection<T>, R> f) Buffers a number of events over a variable time interval and then forwards the events to an accumulator function.Methods in org.osgi.util.pushstream with parameters of type PushStreamModifier and TypeMethodDescription<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventSource<T>, T, U> PushStreamProvider.buildEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.private <T> PushStream
<T> PushStreamProvider.cleanupThreads
(boolean closeExecutorOnClose, Executor workerToUse, boolean releaseSchedulerOnClose, PushStream<T> stream) <T> PushEventSource
<T> PushStreamProvider.createEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.AbstractPushStreamImpl.merge
(PushStream<? extends T> source) PushStream.merge
(PushStream<? extends T> source) Merge in the events from another PushStream.Method parameters in org.osgi.util.pushstream with type arguments of type PushStreamModifier and TypeMethodDescription<R> PushStream
<R> AbstractPushStreamImpl.flatMap
(Function<? super T, ? extends PushStream<? extends R>> mapper) <R> PushStream
<R> PushStream.flatMap
(Function<? super T, ? extends PushStream<? extends R>> mapper) Flat map the payload value (turn one event into 0..n events of potentially another type).