(client tailnet.WorkspaceUpdatesClient)
| 2295 | } |
| 2296 | |
| 2297 | func (f fakeWorkspaceUpdatesController) New(client tailnet.WorkspaceUpdatesClient) tailnet.CloserWaiter { |
| 2298 | resps := make(chan tailnet.CloserWaiter) |
| 2299 | call := &newWorkspaceUpdatesCall{ |
| 2300 | client: client, |
| 2301 | resp: resps, |
| 2302 | } |
| 2303 | select { |
| 2304 | case <-f.ctx.Done(): |
| 2305 | cw := newFakeCloserWaiter() |
| 2306 | cw.errCh <- errTimeoutOnFake |
| 2307 | return cw |
| 2308 | case f.calls <- call: |
| 2309 | // OK |
| 2310 | } |
| 2311 | select { |
| 2312 | case <-f.ctx.Done(): |
| 2313 | cw := newFakeCloserWaiter() |
| 2314 | cw.errCh <- errTimeoutOnFake |
| 2315 | return cw |
| 2316 | case resp := <-resps: |
| 2317 | return resp |
| 2318 | } |
| 2319 | } |
| 2320 | |
| 2321 | func newFakeUpdatesController(ctx context.Context, t *testing.T) *fakeWorkspaceUpdatesController { |
| 2322 | return &fakeWorkspaceUpdatesController{ |
nothing calls this directly
no test coverage detected