Moved streaming runner to stream package
Add context to completion callback, propagate TimeoutException