类 reactor.core.publisher.ConnectableFlux的使用 (reactor-3)

使用ConnectableFlux的程序包
程序包	说明
reactor.core.publisher	Provide main Reactive APIs in `Flux` and `Mono`, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.
reactor.test	Main test components supporting the testing and assertion of publishers.

返回ConnectableFlux的reactor.core.publisher中的方法
限定符和类型	方法和说明
`ConnectableFlux<T>`	ConnectableFlux.`hide()`
`ConnectableFlux<T>`	Flux.`publish()` Prepare a `ConnectableFlux` which shares this `Flux` sequence and dispatches values to subscribers in a backpressure-aware manner.
`ConnectableFlux<T>`	Flux.`publish(int prefetch)` Prepare a `ConnectableFlux` which shares this `Flux` sequence and dispatches values to subscribers in a backpressure-aware manner.
`ConnectableFlux<T>`	Flux.`replay()` Turn this `Flux` into a hot source and cache last emitted signals for further `Subscriber`.
`ConnectableFlux<T>`	Flux.`replay(java.time.Duration ttl)` Turn this `Flux` into a connectable hot source and cache last emitted signals for further `Subscriber`.
`ConnectableFlux<T>`	Flux.`replay(java.time.Duration ttl, Scheduler timer)` Turn this `Flux` into a connectable hot source and cache last emitted signals for further `Subscriber`.
`ConnectableFlux<T>`	Flux.`replay(int history)` Turn this `Flux` into a connectable hot source and cache last emitted signals for further `Subscriber`.
`ConnectableFlux<T>`	Flux.`replay(int history, java.time.Duration ttl)` Turn this `Flux` into a connectable hot source and cache last emitted signals for further `Subscriber`.
`ConnectableFlux<T>`	Flux.`replay(int history, java.time.Duration ttl, Scheduler timer)` Turn this `Flux` into a connectable hot source and cache last emitted signals for further `Subscriber`.

reactor.test中ConnectableFlux的子类
限定符和类型	类和说明
`static class`	`MockUtils.TestScannableConnectableFlux<T>` An abstract class that can be used to mock a `Scannable` `ConnectableFlux`.

类的使用reactor.core.publisher.ConnectableFlux