Class OperatorSequenceEqual

java.lang.Object
rx.internal.operators.OperatorSequenceEqual

public final class OperatorSequenceEqual extends Object
Returns an Observable that emits a single Boolean value that indicates whether two source Observables emit sequences of items that are equivalent to each other.
  • Field Details

    • LOCAL_ONCOMPLETED

      static final Object LOCAL_ONCOMPLETED
      NotificationLite doesn't work as zip uses it.
  • Constructor Details

    • OperatorSequenceEqual

      private OperatorSequenceEqual()
  • Method Details

    • materializeLite

      static <T> Observable<Object> materializeLite(Observable<T> source)
    • sequenceEqual

      public static <T> Observable<Boolean> sequenceEqual(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T,? super T,Boolean> equality)
      Tests whether two Observable sequences are identical, emitting true if both sequences complete without differing, and false if the two sequences diverge at any point.
      Type Parameters:
      T - the value type
      Parameters:
      first - the first of the two Observables to compare
      second - the second of the two Observables to compare
      equality - a function that tests emissions from each Observable for equality
      Returns:
      an Observable that emits true if first and second complete after emitting equal sequences of items, false if at any point in their sequences the two Observables emit a non-equal item.