raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

cleaning up documentation on deprecated actorSubscriber and actorPublisher

Browse source
This commit is contained in:
svezfaz 2018-02-10 20:49:23 +00:00
parent 232b4d0d7a
commit 60f5b9690e
2 changed files with 0 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

23
akka-docs/src/main/paradox/stream/stages-overview.md
View file

@ -201,16 +201,6 @@ Defers creation and materialization of a `Source` until there is demand.
---------------------------------------------------------------
### actorPublisher
Wrap an actor extending `ActorPublisher` as a source.
**emits** depends on the actor implementation
**completes** when the actor stops
---------------------------------------------------------------
### actorRef
Materialize an `ActorRef`, sending messages to it will emit them on the stream. The actor contain
@ -508,19 +498,6 @@ to provide back pressure onto the sink.
---------------------------------------------------------------
### actorSubscriber
Create an actor from a `Props` upon materialization, where the actor implements `ActorSubscriber`, which will
receive the elements from the stream.
Materializes into an `ActorRef` to the created actor.
**cancels** when the actor terminates
**backpressures** depends on the actor implementation
---------------------------------------------------------------
### asPublisher
Integration with Reactive Streams, materializes into a `org.reactivestreams.Publisher`.

6
akka-docs/src/main/paradox/stream/stream-integrations.md
View file

@ -503,12 +503,6 @@ These can be consumed by other Reactive Stream libraries or used as an Akka Stre
@@@ warning
`ActorPublisher` and `ActorSubscriber` will probably be deprecated in future versions of Akka.
@@@
@@@ warning
`ActorPublisher` and `ActorSubscriber` cannot be used with remote actors,
because if signals of the Reactive Streams protocol (e.g. `request`) are lost the
the stream may deadlock.