add tests for restarting stream