fail

decode encode

filter

StreamDecoder

firstAfter

StreamDecoder

flatMap

StreamDecoder

flatMapP

StreamDecoder

fuse

StreamGenCodec