scala - Akka streams - emit materialized value -


when creating graph using builder can emit message once stream has been materialized:

builder.materializedvalue.map(actor => userjoined(actor)) 

how can achieve same effect when creating flow without graph api?

val source = source.actorref[message](5, overflowstrategy.dropnew) val initmessage = srcactor.mapmaterializedvalue(a => playerjoined(a)) 

how can make initmessage emitted merged source , passed sink without graph dsl api?


Comments

Popular posts from this blog

php - trouble displaying mysqli database results in correct order -

depending on nth recurrence of job in control M -

sql server - Cannot query correctly (MSSQL - PHP - JSON) -