Package | Description |
---|---|
io.reactivex.processors |
Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
|
Modifier and Type | Method and Description |
---|---|
static <T> PublishProcessor<T> |
PublishProcessor.create()
Constructs a PublishProcessor.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.