| 177 | tryToSend(); |
| 178 | } |
| 179 | void subscribe(Sender* s) { |
| 180 | DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") subscribe Sender: " << s << "\n";); |
| 181 | subscriptions_[s] = 0; |
| 182 | } |
| 183 | void unsubscribe(Sender* s) { |
| 184 | DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") unsubscribe Sender: " << s << "\n";); |
| 185 | // If we're about to erase the current subscription move on |