Class OperatorGroupBy<T,​K,​V>

    • Field Detail

      • keySelector

        final Func1<? super T,​? extends K> keySelector
      • valueSelector

        final Func1<? super T,​? extends V> valueSelector
      • bufferSize

        final int bufferSize
      • delayError

        final boolean delayError
      • mapFactory

        final Func1<Action1<K>,​java.util.Map<K,​java.lang.Object>> mapFactory
    • Constructor Detail

      • OperatorGroupBy

        public OperatorGroupBy​(Func1<? super T,​? extends K> keySelector)
      • OperatorGroupBy

        public OperatorGroupBy​(Func1<? super T,​? extends K> keySelector,
                               Func1<? super T,​? extends V> valueSelector)
      • OperatorGroupBy

        public OperatorGroupBy​(Func1<? super T,​? extends K> keySelector,
                               Func1<? super T,​? extends V> valueSelector,
                               Func1<Action1<K>,​java.util.Map<K,​java.lang.Object>> mapFactory)
      • OperatorGroupBy

        public OperatorGroupBy​(Func1<? super T,​? extends K> keySelector,
                               Func1<? super T,​? extends V> valueSelector,
                               int bufferSize,
                               boolean delayError,
                               Func1<Action1<K>,​java.util.Map<K,​java.lang.Object>> mapFactory)