()
| 431 | } |
| 432 | |
| 433 | func (t *Transport) Resume() { |
| 434 | t.mu.RLock() |
| 435 | defer t.mu.RUnlock() |
| 436 | for _, p := range t.peers { |
| 437 | p.(Pausable).Resume() |
| 438 | } |
| 439 | } |
| 440 | |
| 441 | // ActivePeers returns a channel that closes when an initial |
| 442 | // peer connection has been established. Use this to wait until the |