object AbstractActorPublisher
Ordering
- Alphabetic
- By Inheritance
Inherited
- AbstractActorPublisher
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Value Members
-
def
create[T](ref: ActorRef): Publisher[T]
Java API compatible with lambda expressions: Create a org.reactivestreams.Publisher backed by a AbstractActorPublisher actor.
Java API compatible with lambda expressions: Create a org.reactivestreams.Publisher backed by a AbstractActorPublisher actor. It can be attached to a org.reactivestreams.Subscriber or be used as an input source for a akka.stream.javadsl.Flow.