WIP on streams as Iterables with closeable concurrent iterators