()
| 751 | } |
| 752 | |
| 753 | func (t *testServiceClientWrapper) getCurrentStreamID() uint32 { |
| 754 | t.mu.RLock() |
| 755 | defer t.mu.RUnlock() |
| 756 | return uint32(2*t.streamsCreated - 1) |
| 757 | } |
| 758 | |
| 759 | func (t *testServiceClientWrapper) EmptyCall(ctx context.Context, in *testpb.Empty, opts ...grpc.CallOption) (*testpb.Empty, error) { |
| 760 | t.mu.Lock() |
no outgoing calls
no test coverage detected