accept streams for data input

Each data event must be a single data unit.