process stream, and merge_ping