mobiuskt-extras/kt.mobius.extras/QueueingEventSubject/subscribe

subscribe

open override fun subscribe(eventConsumer: Consumer<E>): Disposable