Flow < ByteString , ByteString , NotUsed > function ( String arg0 ) { ByteString loc0 = ByteString . fromString ( arg0 ) ; return Flow . of ( ByteString . class ) . map ( ( msg ) -> { return formatted ( loc0 , msg ) ; } ) . prepend ( Source . single ( initialChunk ) ) ; }
produces a flow of bytestring with a prepended block and a script wrapper . concode_field_sep ByteString initialChunk concode_field_sep Flow<String,ByteString,NotUsed> string concode_elem_sep ByteString formatted concode_elem_sep Flow<JsonNode,ByteString,NotUsed> json