hu.akarnokd.rxjava2.operators

Class FlowableTransformers

java.lang.Object

hu.akarnokd.rxjava2.operators.FlowableTransformers

public final class FlowableTransformers
extends java.lang.Object

Additional operators in the form of FlowableTransformer, use Flowable.compose(FlowableTransformer) to apply the operators to an existing sequence.

Since:

0.7.2

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.FlowableTransformer<T,java.util.List<T>>	bufferUntil(io.reactivex.functions.Predicate<? super T> predicate) Buffers elements into a List until the given predicate returns true at which point a new empty buffer is started.
static <T,C extends java.util.Collection<? super T>> io.reactivex.FlowableTransformer<T,C>	bufferUntil(io.reactivex.functions.Predicate<? super T> predicate, java.util.concurrent.Callable<C> bufferSupplier) Buffers elements into a custom collection until the given predicate returns true at which point a new empty custom collection is started.
static <T> io.reactivex.FlowableTransformer<T,java.util.List<T>>	bufferWhile(io.reactivex.functions.Predicate<? super T> predicate) Buffers elements into a List while the given predicate returns true; if the predicate returns false for an item, a new buffer is created with the specified item.
static <T,C extends java.util.Collection<? super T>> io.reactivex.FlowableTransformer<T,C>	bufferWhile(io.reactivex.functions.Predicate<? super T> predicate, java.util.concurrent.Callable<C> bufferSupplier) Buffers elements into a custom collection while the given predicate returns true; if the predicate returns false for an item, a new collection is created with the specified item.
static <T> io.reactivex.FlowableTransformer<T,T>	valve(org.reactivestreams.Publisher<java.lang.Boolean> other) Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source.
static <T> io.reactivex.FlowableTransformer<T,T>	valve(org.reactivestreams.Publisher<java.lang.Boolean> other, boolean defaultOpen) Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source and starts with the specivied valve state.
static <T> io.reactivex.FlowableTransformer<T,T>	valve(org.reactivestreams.Publisher<java.lang.Boolean> other, boolean defaultOpen, int bufferSize) Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source and starts with the specivied valve state and the specified buffer size hint.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

valve

@SchedulerSupport(value="none")
 @BackpressureSupport(value=PASS_THROUGH)
public static <T> io.reactivex.FlowableTransformer<T,T> valve(org.reactivestreams.Publisher<java.lang.Boolean> other)

Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source.

Properties:

• The operator starts with an open valve.
• If the other Publisher completes, the sequence terminates with an IllegalStateException.
• The operator doesn't run on any particular Scheduler.
• The operator is a pass-through for backpressure and uses an internal unbounded buffer of size Flowable.bufferSize() to hold onto values if the valve is closed.

Type Parameters:

T - the value type of the main source

Parameters:

other - the other source

Returns:

the new FlowableTransformer instance

Throws:

java.lang.NullPointerException - if other is null

Since:

0.7.2

valve

@SchedulerSupport(value="none")
 @BackpressureSupport(value=PASS_THROUGH)
public static <T> io.reactivex.FlowableTransformer<T,T> valve(org.reactivestreams.Publisher<java.lang.Boolean> other,
                                                                                                                                          boolean defaultOpen)

Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source and starts with the specivied valve state.

Properties:

• If the other Publisher completes, the sequence terminates with an IllegalStateException.
• The operator doesn't run on any particular Scheduler.
• The operator is a pass-through for backpressure and uses an internal unbounded buffer of size Flowable.bufferSize() to hold onto values if the valve is closed.

Type Parameters:

T - the value type of the main source

Parameters:

other - the other source

defaultOpen - should the valve start as open?

Returns:

the new FlowableTransformer instance

Throws:

java.lang.NullPointerException - if other is null

Since:

0.7.2

valve

@SchedulerSupport(value="none")
 @BackpressureSupport(value=PASS_THROUGH)
public static <T> io.reactivex.FlowableTransformer<T,T> valve(org.reactivestreams.Publisher<java.lang.Boolean> other,
                                                                                                                                          boolean defaultOpen,
                                                                                                                                          int bufferSize)

Relays values until the other Publisher signals false and resumes if the other Publisher signals true again, like closing and opening a valve and not losing any items from the main source and starts with the specivied valve state and the specified buffer size hint.

Properties:

• If the other Publisher completes, the sequence terminates with an IllegalStateException.
• The operator doesn't run on any particular Scheduler.

Type Parameters:

T - the value type of the main source

Parameters:

other - the other source

defaultOpen - should the valve start as open?

bufferSize - the buffer size hint (the chunk size of the underlying unbounded buffer)

Returns:

the new FlowableTransformer instance

Throws:

java.lang.IllegalArgumentException - if bufferSize <= 0

java.lang.NullPointerException - if other is null

Since:

0.7.2

bufferWhile

@SchedulerSupport(value="none")
 @BackpressureSupport(value=FULL)
public static <T> io.reactivex.FlowableTransformer<T,java.util.List<T>> bufferWhile(io.reactivex.functions.Predicate<? super T> predicate)

Buffers elements into a List while the given predicate returns true; if the predicate returns false for an item, a new buffer is created with the specified item.

Type Parameters:

T - the source value type

Parameters:

predicate - the predicate receiving the current value and if returns false, a new buffer is created with the specified item

Returns:

the new Flowable instance

Since:

0.8.0

bufferWhile

@SchedulerSupport(value="none")
 @BackpressureSupport(value=FULL)
public static <T,C extends java.util.Collection<? super T>> io.reactivex.FlowableTransformer<T,C> bufferWhile(io.reactivex.functions.Predicate<? super T> predicate,
                                                                                                                                                                                  java.util.concurrent.Callable<C> bufferSupplier)

Buffers elements into a custom collection while the given predicate returns true; if the predicate returns false for an item, a new collection is created with the specified item.

Type Parameters:

T - the source value type

C - the collection type

Parameters:

predicate - the predicate receiving the current value and if returns false, a new collection is created with the specified item

bufferSupplier - the callable that returns a fresh collection

Returns:

the new Flowable instance

Since:

0.8.0

bufferUntil

@SchedulerSupport(value="none")
 @BackpressureSupport(value=FULL)
public static <T> io.reactivex.FlowableTransformer<T,java.util.List<T>> bufferUntil(io.reactivex.functions.Predicate<? super T> predicate)

Buffers elements into a List until the given predicate returns true at which point a new empty buffer is started.

Type Parameters:

T - the source value type

Parameters:

predicate - the predicate receiving the current itam and if returns true, the current buffer is emitted and a fresh empty buffer is created

Returns:

the new Flowable instance

Since:

0.8.0

bufferUntil

@SchedulerSupport(value="none")
 @BackpressureSupport(value=FULL)
public static <T,C extends java.util.Collection<? super T>> io.reactivex.FlowableTransformer<T,C> bufferUntil(io.reactivex.functions.Predicate<? super T> predicate,
                                                                                                                                                                                  java.util.concurrent.Callable<C> bufferSupplier)

Buffers elements into a custom collection until the given predicate returns true at which point a new empty custom collection is started.

Type Parameters:

T - the source value type

C - the collection type

Parameters:

predicate - the predicate receiving the current itam and if returns true, the current collection is emitted and a fresh empty collection is created

bufferSupplier - the callable that returns a fresh collection

Returns:

the new Flowable instance

Since:

0.8.0