USe the new chained stream to reassemble partial messages