Class GroupedFlowable<K,T>

java.lang.Object
io.reactivex.rxjava3.core.Flowable<T>
io.reactivex.rxjava3.flowables.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:
  • Field Details

    • key

      final K key
  • Constructor Details

    • GroupedFlowable

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

    • 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