streaming solved properly, fixed thread pool, updated examples