Modify _forward method to check for _done and

refactored split stream test.