()
| 1014 | } |
| 1015 | |
| 1016 | func (fr *fetchResult) closed() bool { |
| 1017 | fr.Lock() |
| 1018 | defer fr.Unlock() |
| 1019 | return fr.done |
| 1020 | } |
| 1021 | |
| 1022 | // Next is used to retrieve the next message from the stream. This |
| 1023 | // method will block until the message is retrieved or timeout is |
no outgoing calls
no test coverage detected