| 172 | tryToSend(); |
| 173 | } |
| 174 | void flow(Sender* s, int c) { |
| 175 | DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") flow: " << c << " to " << s << "\n";); |
| 176 | subscriptions_[s] = c; |
| 177 | tryToSend(); |
| 178 | } |
| 179 | void subscribe(Sender* s) { |
| 180 | DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") subscribe Sender: " << s << "\n";); |
| 181 | subscriptions_[s] = 0; |
no outgoing calls
no test coverage detected