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.service.typedevent.monitor	Typed Event Monitoring 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 and Description
PushStream<LogEntry>	LogStreamProvider.createStream(LogStreamProvider.Options... options) Create a PushStream of LogEntry objects.

Uses of PushStream in org.osgi.service.typedevent.monitor

Methods in org.osgi.service.typedevent.monitor that return PushStream

Modifier and Type	Method and Description
PushStream<MonitorEvent>	TypedEventMonitor.monitorEvents() Get a stream of events, starting now.
PushStream<MonitorEvent>	TypedEventMonitor.monitorEvents(Instant history) Get a stream of events, including historical data events prior to the supplied time
PushStream<MonitorEvent>	TypedEventMonitor.monitorEvents(int history) Get a stream of events, including up to the requested number of historical data events.

Uses of PushStream in org.osgi.util.pushstream

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

Modifier and Type	Method and Description
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>	PushStream.asyncMap(int n, int delay, Function<? super T,Promise<? extends R>> mapper) Asynchronously map the payload values.
PushStream<T>	PushStream.buffer() Buffer the events in a queue using default values for the queue size and other behaviors.
<R> PushStream<R>	PushStream.coalesce(Function<? super T,Optional<R>> f) Coalesces a number of events into a new type of event.
<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.
<T> PushStream<T>	PushStreamProvider.createStream(PushEventSource<T> eventSource) Create a stream with the default configured buffer, executor size, queue, queue policy and pushback policy.
PushStream<T>	PushStream.distinct() Remove any duplicates.
PushStream<T>	PushStream.filter(Predicate<? super T> predicate) Only pass events downstream when the predicate tests true.
<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>	PushStream.fork(int n, int delay, Executor e) Execute the downstream events in up to n background threads.
PushStream<T>	PushStream.limit(Duration maxTime) Automatically close the channel after the given amount of time has elapsed.
PushStream<T>	PushStream.limit(long maxSize) Automatically close the channel after the maxSize number of elements is received.
<R> PushStream<R>	PushStream.map(Function<? super T,? extends R> mapper) Map a payload value.
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>	PushStream.onClose(Runnable closeHandler) Provide a handler that must be run after the PushStream is closed.
PushStream<T>	PushStream.onError(Consumer<? super Throwable> errorHandler) Provide a handler that will be called if the PushStream is closed with an event of type PushEvent.EventType.ERROR.
PushStream<T>	PushStream.sequential() Ensure that any events are delivered sequentially.
PushStream<T>	PushStream.skip(long n) Skip a number of events in the channel.
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>[]	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>	PushStream.timeout(Duration idleTime) Automatically fail the channel if no events are received for the indicated length of time.
<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, 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, 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.

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

Modifier and Type	Method and Description
<T,U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream) Convert an PushStream into an PushEventSource.
<T> PushEventSource<T>	PushStreamProvider.createEventSourceFromStream(PushStream<T> stream) Convert an PushStream into an PushEventSource.
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 and Description
<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).