stream_guard.go
stream_guard_test.go