fail

decode encode

filter

StreamDecoder

firstAfter

StreamDecoder

flatMap

StreamDecoder

flatMapS

StreamDecoder

fuse

StreamGenCodec