Implemented reactive streams (pt1)