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

aws api gateway - SerializationException in posting new Records via Dynamodb Proxy Service in API -

asp.net - Problems sending emails from forum -