code: func (s *receiveStream) closeForShutdown(err error) {
  	s.mutex.Lock()
  	s.closedForShutdown = true
  	s.closeForShutdownErr = err
  	s.mutex.Unlock()
  	s.signalRead()
  }
docs: // CloseForShutdown closes a stream abruptly.
  // It makes Read unblock (and return the error) immediately.
  // The peer will NOT be informed about this: the stream is closed without sending a FIN or RESET.