filter_stream :: StreamDemux :: with_streams
init with_streams(streams: Array[Writer]) do _streams = streams end