(bf stats.Features)
| 464 | } |
| 465 | |
| 466 | func makeFuncUnconstrainedStreamPreloaded(bf stats.Features) (rpcSendFunc, rpcRecvFunc, rpcCleanupFunc) { |
| 467 | streams, req, cleanup := setupStream(bf, true) |
| 468 | |
| 469 | preparedMsg := prepareMessages(streams, req) |
| 470 | |
| 471 | return func(cn, pos int) { |
| 472 | streams[cn][pos].SendMsg(preparedMsg[cn][pos]) |
| 473 | }, func(cn, pos int) { |
| 474 | streams[cn][pos].Recv() |
| 475 | }, cleanup |
| 476 | } |
| 477 | |
| 478 | func makeFuncUnconstrainedStream(bf stats.Features) (rpcSendFunc, rpcRecvFunc, rpcCleanupFunc) { |
| 479 | streams, req, cleanup := setupStream(bf, true) |
no test coverage detected