ensure flowing stream using stream-exhaust, add test