MarkProcessedCallID records a call_id as published so it won't be re-processed in subsequent request cycles.
(sessionID, callID string)
| 291 | // MarkProcessedCallID records a call_id as published so it won't be |
| 292 | // re-processed in subsequent request cycles. |
| 293 | func (m *Manager) MarkProcessedCallID(sessionID, callID string) { |
| 294 | sess := m.Get(sessionID) |
| 295 | if sess == nil { |
| 296 | return |
| 297 | } |
| 298 | sess.mu.Lock() |
| 299 | defer sess.mu.Unlock() |
| 300 | sess.processedCallIDs[callID] = true |
| 301 | } |
| 302 | |
| 303 | // Subscribe creates a channel that receives command results for a session. |
| 304 | func (m *Manager) Subscribe(sessionID, subID string) <-chan *CommandResult { |