Struct stream

internal/xds/clients/xdsclient/test/ads_stream_flow_control_test.go:137–140

}

type stream struct {
	stream grpc.ClientStream
	recvCh chan struct{}
}

func (s *stream) Send(msg []byte) error {
	return s.stream.SendMsg(msg)