(res protocolBody)
| 1093 | } |
| 1094 | |
| 1095 | func makeResponsePromise(res protocolBody) *responsePromise { |
| 1096 | promise := &responsePromise{ |
| 1097 | response: res, |
| 1098 | packets: make(chan []byte), |
| 1099 | errors: make(chan error), |
| 1100 | } |
| 1101 | return promise |
| 1102 | } |
| 1103 | |
| 1104 | // b.lock must be held by caller |
| 1105 | func (b *Broker) sendWithPromise(rb protocolBody, promise *responsePromise) error { |
no outgoing calls
no test coverage detected