Hi all,
I'm trying to wrap my mind around how to use a ClusterRouterGroup with
GraphStage API. I have some old code that I'd like to refactor to move
away from the deprecated ActorPublisher/Subscriber APIs. The code is
generally something like this:
val router = ClusterRouterGroup(
Ok, I figured it out on my own (in Scala).
val toBodyPart = (src : String) => {
val file = Paths.get(src)
Multipart.General.BodyPart(HttpEntity(MediaType.customBinary(
"application", "dicom", MediaType.Compressible), file.toFile().length(),
