Package au.gov.amsa.util.rx

Class OperatorFlattenIterable<T>

  • All Implemented Interfaces:
    rx.functions.Func1<rx.Subscriber<? super T>,​rx.Subscriber<? super java.lang.Iterable<T>>>, rx.functions.Function, rx.Observable.Operator<T,​java.lang.Iterable<T>>
    public class OperatorFlattenIterable<T>
extends java.lang.Object
implements rx.Observable.Operator<T,​java.lang.Iterable<T>>

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      rx.Subscriber<? super java.lang.Iterable<T>> call​(rx.Subscriber<? super T> subscriber)  
      static <T> rx.Observable.Operator<T,​java.lang.Iterable<T>> flatten()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • OperatorFlattenIterable

        public OperatorFlattenIterable()

    • Method Detail

      • flatten

        public static <T> rx.Observable.Operator<T,​java.lang.Iterable<T>> flatten()

      • call

        public rx.Subscriber<? super java.lang.Iterable<T>> call​(rx.Subscriber<? super T> subscriber)
        Specified by:
        call in interface rx.functions.Func1<rx.Subscriber<? super T>,​rx.Subscriber<? super java.lang.Iterable<T>>>