Flow < String , ByteString , NotUsed > function ( String arg0 ) { return Flow . of ( String . class ) . map ( str -> { return ByteString . fromString ( "srini_string" + StringEscapeUtils . escapeEcmaScript ( str ) + "srini_string" ) ; } ) . via ( flow ( arg0 ) ) ; }
produces a flow of escaped bytestring from a series of string elements . calls out to comet.flow internally . concode_field_sep ByteString initialChunk concode_field_sep ByteString formatted concode_elem_sep Flow<JsonNode,ByteString,NotUsed> json concode_elem_sep Flow<ByteString,ByteString,NotUsed> flow