grpc/streambuffer/streambuffer.go
func (s *Stream) CloseRecv() {
	s.mu.Lock()
	if s.recvBuffer != nil {
		close(s.recvBuffer)
		s.recvBuffer = nil
	}
	s.mu.Unlock()
}
func (s *Stream) CloseRecv() {
	s.mu.Lock()
	if s.recvBuffer != nil {
		close(s.recvBuffer)
		s.recvBuffer = nil
	}
	s.mu.Unlock()
}
// CloseRecv closes the receive channel