Comment renvoyer une erreur depuis une promesse interne ?

Lors de l'écriture de code, nous devons souvent faire face à certaines situations d'erreur possibles. Cependant, nous devons parfois renvoyer une erreur à l’intérieur d’une fonction ou d’une méthode afin qu’elle puisse être traitée correctement lorsque la fonction ou la méthode est appelée. En PHP, nous avons plusieurs façons d'y parvenir. Cet article explique comment renvoyer des erreurs à partir des promesses pour aider les développeurs à mieux gérer les situations d'erreur.

Contenu de la question

J'ai une fonction (sendall），如果 kgo.produce （文档在这里）中发生错误，我想让它返回 errorComment puis-je l'arrêter en boucle et renvoyer une erreur ?

).

func (k *buffer) sendAll() error {
    for _, record := range k.buffer {
        kgo.Produce(ctx, &record, func(r *kgo.Record, err error) {
            if err != nil {
                fmt.Printf("record had a produce error: %v\n", err)
                
                // How do I return an error here and exit sendAll function?
                
            }
        })
    }
    return nil
}

Workaround

Il me semble que vous pouvez vous en sortir en cochant simplement la variable "local".

func (k *buffer) sendAll() error {

    var loop error

    for _, record := range k.buffer {
        if loop != nil {
            break
        }
        kgo.Produce(ctx, &record, func(r *kgo.Record, err error) {
           
            if err != nil {
                fmt.Printf("record had a produce error: %v\n", err)
                
                // How do I return an error here and exit sendAll function?
                loop = err
            }
        })
    }
    return loop
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!