ensure flowing stream using stream-exhaust, add test - closes #11