Uses of Interface
io.reactivex.rxjava3.operators.QueueFuseable

Packages that use QueueFuseable
Package
Description
 
Base interfaces and types for supporting operator-fusion.
 
 
 
 
 
 
 
 
 
Classes and interfaces for writing advanced operators within and outside RxJava.
Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.