apply

open override fun apply(t: Flowable<Throwable>): Flowable<*>