simpler stream rollback without an extra goroutine