You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Motivation:
it would be very common when we want a dedicated graph run on x dispatcher, I suggest we add something like the reactor-core, which can be much clear than the current addAttributes(ActorAttributes.dispatcher(dispatcher).
publishOn(dispatcher:String) for Source
subscribeOn(dispatcher:String) for Sink
runOn(dispatcher:String) for RunnableGraph
eg:
def runOn(dispatcher:String)(implicit materializer: Materializer): Mat =
materializer.materialize(addAttributes(ActorAttributes.dispatcher(dispatcher)))
This discussion was converted from issue #925 on January 10, 2024 07:34.
Heading
Bold
Italic
Quote
Code
Link
Numbered list
Unordered list
Task list
Attach files
Mention
Reference
Menu
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
Motivation:
it would be very common when we want a dedicated graph run on x dispatcher, I suggest we add something like the reactor-core, which can be much clear than the current
addAttributes(ActorAttributes.dispatcher(dispatcher)
.publishOn(dispatcher:String)
for SourcesubscribeOn(dispatcher:String)
for SinkrunOn(dispatcher:String)
for RunnableGrapheg:
Beta Was this translation helpful? Give feedback.
All reactions