process stream in new thread and return immediately
make volume-pools return a vector when the pool is full, not a PersistentQueue
enable overflowing of multiple events