Uses of Interface
org.osgi.util.pushstream.PushStream

Packages that use PushStream

Package	Description
org.osgi.service.log.stream	Log Stream Package Version 1.0.
org.osgi.util.pushstream	Push Stream Package Version 1.0.

Uses of PushStream in org.osgi.service.log.stream

Methods in org.osgi.service.log.stream that return PushStream

Modifier and Type	Method	Description
PushStream<LogEntry>	LogStreamProvider.createStream(LogStreamProvider.Options... options)	Create a PushStream of LogEntry objects.

Uses of PushStream in org.osgi.util.pushstream

Classes in org.osgi.util.pushstream that implement PushStream

Modifier and Type	Class	Description
(package private) class	AbstractPushStreamImpl<T>
(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>>>

Methods in org.osgi.util.pushstream that return PushStream

Modifier and Type	Method	Description
PushStream<T>	AbstractPushStreamImpl.adjustBackPressure(LongUnaryOperator adjustment)
PushStream<T>	AbstractPushStreamImpl.adjustBackPressure(ToLongBiFunction<T,Long> adjustment)
PushStream<T>	PushStream.adjustBackPressure(LongUnaryOperator adjustment)	Changes the back-pressure propagated by this pipeline stage.
PushStream<T>	PushStream.adjustBackPressure(ToLongBiFunction<T,Long> adjustment)	Changes the back-pressure propagated by this pipeline stage.
<R> PushStream<R>	AbstractPushStreamImpl.asyncMap(int n, int delay, Function<? super T,Promise<? extends R>> mapper)
<R> PushStream<R>	PushStream.asyncMap(int n, int delay, Function<? super T,Promise<? extends R>> mapper)	Asynchronously map the payload values.
PushStream<T>	AbstractPushStreamImpl.buffer()
PushStream<T>	PushStream.buffer()	Buffer the events in a queue using default values for the queue size and other behaviors.
PushStream<T>	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>	AbstractPushStreamImpl.coalesce(Function<? super T,Optional<R>> accumulator)
<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>	PushStream.coalesce(Function<? super T,Optional<R>> f)	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)
PushStream<T>	AbstractPushStreamImpl.distinct()
PushStream<T>	PushStream.distinct()	Remove any duplicates.
PushStream<T>	AbstractPushStreamImpl.filter(Predicate<? super T> predicate)
PushStream<T>	PushStream.filter(Predicate<? super T> predicate)	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).
PushStream<T>	AbstractPushStreamImpl.fork(int n, int delay, Executor ex)
PushStream<T>	PushStream.fork(int n, int delay, Executor e)	Execute the downstream events in up to n background threads.
PushStream<T>	AbstractPushStreamImpl.limit(long maxSize)
PushStream<T>	AbstractPushStreamImpl.limit(Duration maxTime)
PushStream<T>	PushStream.limit(long maxSize)	Automatically close the channel after the maxSize number of elements is received.
PushStream<T>	PushStream.limit(Duration maxTime)	Automatically close the channel after the given amount of time has elapsed.
<R> PushStream<R>	AbstractPushStreamImpl.map(Function<? super T,? extends R> mapper)
<R> PushStream<R>	PushStream.map(Function<? super T,? extends R> mapper)	Map a payload value.
PushStream<T>	AbstractPushStreamImpl.merge(PushEventSource<? extends T> source)
PushStream<T>	AbstractPushStreamImpl.merge(PushStream<? extends T> source)
PushStream<T>	PushStream.merge(PushEventSource<? extends T> source)	Merge in the events from another source.
PushStream<T>	PushStream.merge(PushStream<? extends T> source)	Merge in the events from another PushStream.
PushStream<T>	AbstractPushStreamImpl.onClose(Runnable closeHandler)
PushStream<T>	PushStream.onClose(Runnable closeHandler)	Must be run after the channel is closed.
PushStream<T>	AbstractPushStreamImpl.onError(Consumer<? super Throwable> closeHandler)
PushStream<T>	PushStream.onError(Consumer<? super Throwable> closeHandler)	Must be run after the channel is closed.
PushStream<T>	AbstractPushStreamImpl.sequential()
PushStream<T>	PushStream.sequential()	Ensure that any events are delivered sequentially.
PushStream<T>	AbstractPushStreamImpl.skip(long n)
PushStream<T>	PushStream.skip(long n)	Skip a number of events in the channel.
PushStream<T>	AbstractPushStreamImpl.sorted()
PushStream<T>	AbstractPushStreamImpl.sorted(Comparator<? super T> comparator)
PushStream<T>	PushStream.sorted()	Sorted the elements, assuming that T extends Comparable.
PushStream<T>	PushStream.sorted(Comparator<? super T> comparator)	Sorted the elements with the given comparator.
PushStream<T>[]	AbstractPushStreamImpl.split(Predicate<? super T>... predicates)
PushStream<T>[]	PushStream.split(Predicate<? super T>... predicates)	Split the events to different streams based on a predicate.
<T> PushStream<T>	PushStreamProvider.streamOf(Executor executor, ScheduledExecutorService scheduler, Stream<T> items)	Create an Unbuffered PushStream from a Java Stream The data from the stream will be pushed into the PushStream asynchronously using the supplied Executor.
<T> PushStream<T>	PushStreamProvider.streamOf(Stream<T> items)	Create an Unbuffered PushStream from a Java Stream The data from the stream will be pushed into the PushStream synchronously as it is opened.
PushStream<T>	AbstractPushStreamImpl.timeout(Duration maxTime)
PushStream<T>	PushStream.timeout(Duration idleTime)	Automatically fail the channel if no events are received for the indicated length of time.
<R> PushStream<R>	AbstractPushStreamImpl.window(Duration time, Executor executor, Function<Collection<T>,R> f)
<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>	PushStream.window(Duration d, Executor executor, 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(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 PushStream

Modifier and Type	Method	Description
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream)	Convert an PushStream into an PushEventSource.
private <T> PushStream<T>	PushStreamProvider.cleanupThreads(boolean closeExecutorOnClose, Executor workerToUse, boolean releaseSchedulerOnClose, PushStream<T> stream)
<T> PushEventSource<T>	PushStreamProvider.createEventSourceFromStream(PushStream<T> stream)	Convert an PushStream into an PushEventSource.
PushStream<T>	AbstractPushStreamImpl.merge(PushStream<? extends T> source)
PushStream<T>	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 PushStream

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