diff --git a/pkg/beam/beam.go b/pkg/beam/beam.go index 88d3ea7c79..2e8895a153 100644 --- a/pkg/beam/beam.go +++ b/pkg/beam/beam.go @@ -30,7 +30,7 @@ type ReceiveSender interface { } const ( - R int = 1 << (32 - 1 - iota) + R = iota W )