Go语言使用emersion/go-imap出现IMAP异常行为的排查求助

我用Go语言基于emersion/go-imap库实现了一个每分钟调用一次的邮件处理函数，出现了以下异常行为：

• 启动程序时无未读邮件，无任何操作；
• 首次检查与第二次检查之间收到两封未读邮件（邮件A和邮件B）；
• 函数正确识别到这两封邮件并送入通道，但返回的两封邮件内容均为空；
• 第二次与第三次检查之间无新邮件，函数却再次识别到邮件B为未读并送入通道，此次邮件内容正常。

对应的代码如下：

func (f *imapMessageFetcher) searchUnreadFetchProcess() error {
    criteria := imap.SearchCriteria{
        Not: []imap.SearchCriteria{{
            Flag: []imap.Flag{imap.FlagSeen},
        }},
    }

    data, err := f.client.Search(&criteria, nil).Wait()
    if err != nil {
        return fmt.Errorf("failed to search for unread messages: %w", err)
    }

    seqNums := data.AllSeqNums()
    if len(seqNums) == 0 {
        return nil
    }
    log.Printf("found %d unread messages\n", len(seqNums))
    seqset := imap.SeqSetNum(seqNums...)

    fetchOptions := &imap.FetchOptions{
        Flags:       true,
        Envelope:    true,
        BodySection: []*imap.FetchItemBodySection{{}},
    }

    fetchCmd := f.client.Fetch(seqset, fetchOptions)
    defer func() {
        err := fetchCmd.Close()
        if err != nil {
            log.Printf("error closing fetchCmd: %d\n", err)
        }
    }()

    for {
        msgData := fetchCmd.Next()
        if msgData == nil {
            fmt.Println("no more messages to read")
            break
        }
        msgBuffer, err := msgData.Collect()
        if err != nil {
            return fmt.Errorf("error collecting message data %d: ", err)
        }
        log.Printf("finished reading message\n")
        f.outputMessages <- msgBuffer
    }
    return nil
}

• 邮件内容未完全同步：刚接收的邮件A和B，服务器可能还在后台完成内容写入、索引构建等操作。此时邮件的元数据（如未读标记）已经可以被搜索到，但实际内容尚未就绪，导致第一次Fetch返回空内容。等到第二次检查时，服务器完成了内容同步，就能正常获取邮件内容。
• 未标记邮件为已读导致重复检测：当前代码仅完成了邮件内容的Fetch操作，没有将邮件标记为Seen（已读）状态。因此邮件B在第一次处理后仍然处于未读状态，会被后续的搜索再次命中。而第二次Fetch时，服务器已经完成了邮件内容的准备，所以能返回正常内容。
• Fetch数据传输未完成：fetchCmd.Next()可能在服务器尚未完全传输邮件数据时就返回了msgData对象，此时调用msgData.Collect()无法获取到完整的邮件内容。第二次Fetch时，服务器端的数据已经完全准备好，因此可以正常收集到邮件内容。

内容的提问来源于stack exchange，提问作者agamendon