TestBlockingWriteClient is a queue_manager WriteClient which will block on any calls to Store(), until the request's Context is cancelled, at which point the `numCalls` property will contain a count of how many times Store() was called.
| 1238 | // point the `numCalls` property will contain a count of how many times Store() |
| 1239 | // was called. |
| 1240 | type TestBlockingWriteClient struct { |
| 1241 | numCalls atomic.Uint64 |
| 1242 | } |
| 1243 | |
| 1244 | func NewTestBlockedWriteClient() *TestBlockingWriteClient { |
| 1245 | return &TestBlockingWriteClient{} |
nothing calls this directly
no outgoing calls
no test coverage detected