| 328 | } |
| 329 | |
| 330 | void Connection::SUnsubscribeChannel(const std::string &channel, uint16_t slot) { |
| 331 | for (auto iter = subscribe_shard_channels_.begin(); iter != subscribe_shard_channels_.end(); iter++) { |
| 332 | if (*iter == channel) { |
| 333 | subscribe_shard_channels_.erase(iter); |
| 334 | owner_->srv->SUnsubscribeChannel(channel, this, slot); |
| 335 | return; |
| 336 | } |
| 337 | } |
| 338 | } |
| 339 | |
| 340 | void Connection::SUnsubscribeAll(const UnsubscribeCallback &reply) { |
| 341 | if (subscribe_shard_channels_.empty()) { |
no test coverage detected