fix #5: stream.merge() -> stream.plug()