object AbstractActorSubscriber
Java API compatible with lambda expressions
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.0) Use
akka.stream.stage.GraphStage
instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.- Source
- ActorSubscriber.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AbstractActorSubscriber
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Value Members
-
def
create[T](ref: ActorRef): Subscriber[T]
Java API compatible with lambda expressions: Attach a AbstractActorSubscriber actor as a org.reactivestreams.Subscriber o a org.reactivestreams.Publisher or akka.stream.javadsl.Flow.