用类实现通用的流处理器。