(bf stats.Features)
| 476 | } |
| 477 | |
| 478 | func makeFuncUnconstrainedStream(bf stats.Features) (rpcSendFunc, rpcRecvFunc, rpcCleanupFunc) { |
| 479 | streams, req, cleanup := setupStream(bf, true) |
| 480 | |
| 481 | return func(cn, pos int) { |
| 482 | streams[cn][pos].Send(req) |
| 483 | }, func(cn, pos int) { |
| 484 | streams[cn][pos].Recv() |
| 485 | }, cleanup |
| 486 | } |
| 487 | |
| 488 | func setupStream(bf stats.Features, unconstrained bool) ([][]testgrpc.BenchmarkService_StreamingCallClient, *testpb.SimpleRequest, rpcCleanupFunc) { |
| 489 | clients, cleanup := makeClients(bf) |
no test coverage detected