()
| 53 | } |
| 54 | |
| 55 | func (tsd *testNoteDispatcher) nextNote() (*SyncNote, error) { |
| 56 | select { |
| 57 | case n := <-tsd.notes: |
| 58 | return n, nil |
| 59 | case <-time.After(time.Second): |
| 60 | return nil, errors.New("timed out waiting for note") |
| 61 | } |
| 62 | } |
| 63 | |
| 64 | func newSyncTest() (*net.TCPListener, *syncClient, *syncServer, *testNoteDispatcher, error) { |
| 65 | ln, addr, err := newLocalTCPListener() |
no outgoing calls
no test coverage detected