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
Post a Comment