Merge pull request #22504 from akka/wip-22436-migration-patriknw
add a note about dispatcher creating async boundary, #22436
This commit is contained in:
commit
8fad451610
2 changed files with 9 additions and 1 deletions
|
|
@ -298,6 +298,14 @@ directly or via ``filtered`` or ``getAttributeList`` you need to take the new or
|
|||
|
||||
.. _Mastering GraphStages, part I: http://blog.akka.io/streams/2016/07/30/mastering-graph-stage-part-1
|
||||
|
||||
Dispatcher attribute
|
||||
--------------------
|
||||
|
||||
The ``ActorAttributes.dispatcher`` attribute is adding an async boundary in 2.5, since that is the typical desired behavior.
|
||||
In 2.4 an explicit `async` marker (``AsyncBoundary`` attribute) had to be added. For example, this means that ``Source`` that
|
||||
defined ``blocking-io-dispatcher`` as default followed by a ``map`` will now be separated by an async boundary, which was not
|
||||
the case in 2.4.
|
||||
|
||||
Remote
|
||||
======
|
||||
|
||||
|
|
|
|||
|
|
@ -291,7 +291,7 @@ object ActorAttributes {
|
|||
val IODispatcher: Dispatcher = ActorAttributes.Dispatcher("akka.stream.default-blocking-io-dispatcher")
|
||||
|
||||
/**
|
||||
* Specifies the name of the dispatcher.
|
||||
* Specifies the name of the dispatcher. This also adds an async boundary.
|
||||
*/
|
||||
def dispatcher(dispatcher: String): Attributes = Attributes(Dispatcher(dispatcher))
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue