Handling errors during parallel execution. Handling error during stream iteration.
Making stream closure simple
Parralel handling of input stream
Logging with actual logger. Removing wait/notify mechanism from input stream reading.