Method finalizeNonGRPCStatus

internal/transport/client_stream.go:75–78

finalizeNonGRPCStatus builds the terminal status by appending the collected response body to the original non-gRPC status message.

()

// finalizeNonGRPCStatus builds the terminal status by appending the collected
// response body to the original non-gRPC status message.
func (s *ClientStream) finalizeNonGRPCStatus() *status.Status {
	msg := fmt.Sprintf("%s\ndata: %q", s.nonGRPCStatus.Message(), s.nonGRPCDataBuf)
	return status.New(s.nonGRPCStatus.Code(), msg)
}

// handleNonGRPCData collects non-gRPC body from the given data frame.
// It returns non-nil value when the stream should be closed with it.