(resp responseWithSource)
| 258 | } |
| 259 | |
| 260 | func (ms *mapSession) addRespToQueue(resp responseWithSource) error { |
| 261 | select { |
| 262 | case ms.changeQueue <- resp: |
| 263 | return nil |
| 264 | case <-ms.sessionAliveCtx.Done(): |
| 265 | return ErrChangeQueueClosed |
| 266 | } |
| 267 | } |
| 268 | |
| 269 | // handleNonKeepAliveMapResponse handles a non-KeepAlive MapResponse (full or |
| 270 | // incremental). |
no test coverage detected