hu.akarnokd.rxjava2.operators

Class ObservableTransformers

java.lang.Object

hu.akarnokd.rxjava2.operators.ObservableTransformers

public final class ObservableTransformers
extends java.lang.Object

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

Since:

0.18.2

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.ObservableTransformer<T,java.lang.Long>	indexOf(io.reactivex.functions.Predicate<? super T> predicate) Returns the first index of an element that matches a predicate or -1L if no elements match.

Methods inherited from class java.lang.Object

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

Method Detail

indexOf

@SchedulerSupport(value="none")
 @BackpressureSupport(value=UNBOUNDED_IN)
public static <T> io.reactivex.ObservableTransformer<T,java.lang.Long> indexOf(io.reactivex.functions.Predicate<? super T> predicate)

Returns the first index of an element that matches a predicate or -1L if no elements match.

Type Parameters:

T - the upstream element type

Parameters:

predicate - the predicate called to test each item, returning true will stop the sequence and return the current item index

Returns:

the new ObservableTransformer instance

Since:

0.18.2