fix: zk add close to avoid zk block.

pull/1284/head
Gordon 2 years ago
parent 688eaac2a6
commit 9ea811c4b8

@ -65,6 +65,7 @@ func (m *msgServer) PullMessageBySeqs(
if len(msgs) == 0 {
log.ZWarn(ctx, "not have msgs", nil, "conversationID", seq.ConversationID, "seq", seq)
continue
}
resp.Msgs[seq.ConversationID] = &sdkws.PullMsgs{Msgs: msgs, IsEnd: isEnd}
} else {

Loading…
Cancel
Save