| 5327 | ) |
| 5328 | |
| 5329 | type fakeStream struct { |
| 5330 | ctx context.Context |
| 5331 | c *sync.Cond |
| 5332 | closed bool |
| 5333 | canceled bool |
| 5334 | sendCalled bool |
| 5335 | job *proto.AcquiredJob |
| 5336 | } |
| 5337 | |
| 5338 | func newFakeStream(ctx context.Context) *fakeStream { |
| 5339 | return &fakeStream{ |
nothing calls this directly
no outgoing calls
no test coverage detected