Implemented streaming for thread