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

Merge pull request #16776 from ktoso/doc-stream-integrations-java-ktoso

Browse source 
=str java documentation for integrating streams
This commit is contained in:
Konrad Malawski 2015-02-06 12:31:55 +01:00
commit 8c54bad00a
3 changed files with 399 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-docs-dev/rst/scala/stream-integrations.rst
View file

@ -34,11 +34,11 @@ elements as have been requested by the stream subscriber. This amount can be inq
``totalDemand``. It is only allowed to use ``onNext`` when ``isActive`` and ``totalDemand>0``,
otherwise ``onNext`` will throw ``IllegalStateException``.
When the stream subscriber requests more elements the ``ActorPublisher.Request`` message
When the stream subscriber requests more elements the ``ActorPublisherMessage.Request`` message
is delivered to this actor, and you can act on that event. The ``totalDemand``
is updated automatically.
When the stream subscriber cancels the subscription the ``ActorPublisher.Cancel`` message
When the stream subscriber cancels the subscription the ``ActorPublisherMessage.Cancel`` message
is delivered to this actor. After that subsequent calls to ``onNext`` will be ignored.
You can complete the stream by calling ``onComplete``. After that you are not allowed to