Class GroupedFlowable<K,​T>

  • Type Parameters:
    K - the type of the key
    T - the type of the items emitted by the GroupedFlowable
    All Implemented Interfaces:
    org.reactivestreams.Publisher<T>
    Direct Known Subclasses:
    FlowableGroupBy.GroupedUnicast

    public abstract class GroupedFlowable<K,​T>
    extends Flowable<T>
    A Flowable that has been grouped by key, the value of which can be obtained with getKey().

    Note: A GroupedFlowable will cache the items it is to emit until such time as it is subscribed to. For this reason, in order to avoid memory leaks, you should not simply ignore those GroupedFlowables that do not concern you. Instead, you can signal to them that they may discard their buffers by applying an operator like take(0) to them.

    See Also:
    Flowable.groupBy(io.reactivex.rxjava3.functions.Function), ReactiveX documentation: GroupBy
    • Field Detail

      • key

        final K key
    • Constructor Detail

      • GroupedFlowable

        protected GroupedFlowable​(@Nullable
                                  K key)
        Constructs a GroupedFlowable with the given key.
        Parameters:
        key - the key
    • Method Detail

      • getKey

        @Nullable
        public K getKey()
        Returns the key that identifies the group of items emitted by this GroupedFlowable.
        Returns:
        the key that the items emitted by this GroupedFlowable were grouped by