generalize Sink -> Consumer.
start implimentation TS packet.