(t *testing.T)
| 971 | } |
| 972 | |
| 973 | func (s) TestServerStatsServerStreamRPC(t *testing.T) { |
| 974 | count := 5 |
| 975 | checkFuncs := []func(t *testing.T, d *gotData, e *expectedData){ |
| 976 | checkInHeader, |
| 977 | checkBegin, |
| 978 | checkInPayload, |
| 979 | checkOutHeader, |
| 980 | } |
| 981 | ioPayFuncs := []func(t *testing.T, d *gotData, e *expectedData){ |
| 982 | checkOutPayload, |
| 983 | } |
| 984 | for i := 0; i < count; i++ { |
| 985 | checkFuncs = append(checkFuncs, ioPayFuncs...) |
| 986 | } |
| 987 | checkFuncs = append(checkFuncs, |
| 988 | checkOutTrailer, |
| 989 | checkEnd, |
| 990 | ) |
| 991 | testServerStats(t, &testConfig{compress: "gzip"}, &rpcConfig{count: count, success: true, callType: serverStreamRPC}, checkFuncs) |
| 992 | } |
| 993 | |
| 994 | func (s) TestServerStatsServerStreamRPCError(t *testing.T) { |
| 995 | count := 5 |
nothing calls this directly
no test coverage detected