beam: move Stream to stream.go
gofmt