code: func (stream *Stream) Recv() (*orderer.StepResponse, error) {
  	start := time.Now()
  	defer func() {
  		if !stream.Logger.IsEnabledFor(zap.DebugLevel) {
  			return
  		}
  		stream.Logger.Debugf("Receive from %s(%s) took %v", stream.NodeName, stream.Endpoint, time.Since(start))
  	}()
  
  	f := func() (*orderer.StepResponse, error) {
  		return stream.Cluster_StepClient.Recv()
  	}
  
  	return stream.operateWithTimeout(f)
  }
docs: // Recv receives a message from a remote cluster member.