Actually working lifecycle management for streams
Less debug messages (writing, reading, worker)