fix race condition in stream subscription overflow, optimize a few things, rename Stream.prefetch/batchSize to capacity