(ctx context.Context, in *testpb.StreamingOutputCallRequest, opts ...grpc.CallOption)
| 771 | } |
| 772 | |
| 773 | func (t *testServiceClientWrapper) StreamingOutputCall(ctx context.Context, in *testpb.StreamingOutputCallRequest, opts ...grpc.CallOption) (testgrpc.TestService_StreamingOutputCallClient, error) { |
| 774 | t.mu.Lock() |
| 775 | defer t.mu.Unlock() |
| 776 | t.streamsCreated++ |
| 777 | return t.TestServiceClient.StreamingOutputCall(ctx, in, opts...) |
| 778 | } |
| 779 | |
| 780 | func (t *testServiceClientWrapper) StreamingInputCall(ctx context.Context, opts ...grpc.CallOption) (testgrpc.TestService_StreamingInputCallClient, error) { |
| 781 | t.mu.Lock() |
nothing calls this directly
no test coverage detected