(t *testing.T)
| 32 | ) |
| 33 | |
| 34 | func TestStreaming(t *testing.T) { |
| 35 | cases := []*testCase{ |
| 36 | // streaming result |
| 37 | {"server-streaming", testdata.ServerStreamingUserTypeDSL, []*sectionExpectation{ |
| 38 | {"server-stream-struct-type", &testdata.ServerStreamingServerStructCode}, |
| 39 | {"server-stream-send", &testdata.ServerStreamingServerSendCode}, |
| 40 | {"server-stream-close", &testdata.ServerStreamingServerCloseCode}, |
| 41 | {"server-stream-set-view", nil}, |
| 42 | {"client-stream-struct-type", &testdata.ServerStreamingClientStructCode}, |
| 43 | {"client-stream-recv", &testdata.ServerStreamingClientRecvCode}, |
| 44 | }}, |
| 45 | {"server-streaming-result-with-views", testdata.ServerStreamingResultWithViewsDSL, []*sectionExpectation{ |
| 46 | {"server-stream-struct-type", &testdata.ServerStreamingResultWithViewsServerStructCode}, |
| 47 | {"server-stream-send", &testdata.ServerStreamingResultWithViewsServerSendCode}, |
| 48 | {"server-stream-set-view", &testdata.ServerStreamingResultWithViewsServerSetViewCode}, |
| 49 | {"client-stream-struct-type", &testdata.ServerStreamingResultWithViewsClientStructCode}, |
| 50 | {"client-stream-recv", &testdata.ServerStreamingResultWithViewsClientRecvCode}, |
| 51 | {"client-stream-set-view", &testdata.ServerStreamingResultWithViewsClientSetViewCode}, |
| 52 | }}, |
| 53 | {"server-streaming-result-collection-with-explicit-views", testdata.ServerStreamingResultCollectionWithExplicitViewDSL, []*sectionExpectation{ |
| 54 | {"server-stream-send", &testdata.ServerStreamingResultCollectionWithExplicitViewServerSendCode}, |
| 55 | {"server-stream-set-view", nil}, |
| 56 | {"client-stream-recv", &testdata.ServerStreamingResultCollectionWithExplicitViewClientRecvCode}, |
| 57 | {"client-stream-set-view", nil}, |
| 58 | }}, |
| 59 | {"server-streaming-primitive", testdata.ServerStreamingRPCDSL, []*sectionExpectation{ |
| 60 | {"server-stream-send", &testdata.ServerStreamingPrimitiveServerSendCode}, |
| 61 | {"client-stream-recv", &testdata.ServerStreamingPrimitiveClientRecvCode}, |
| 62 | }}, |
| 63 | {"server-streaming-array", testdata.ServerStreamingArrayDSL, []*sectionExpectation{ |
| 64 | {"server-stream-send", &testdata.ServerStreamingArrayServerSendCode}, |
| 65 | {"client-stream-recv", &testdata.ServerStreamingArrayClientRecvCode}, |
| 66 | }}, |
| 67 | {"server-streaming-map", testdata.ServerStreamingMapDSL, []*sectionExpectation{ |
| 68 | {"server-stream-send", &testdata.ServerStreamingMapServerSendCode}, |
| 69 | {"client-stream-recv", &testdata.ServerStreamingMapClientRecvCode}, |
| 70 | }}, |
| 71 | {"server-streaming-shared-result", testdata.ServerStreamingSharedResultRPCDSL, []*sectionExpectation{ |
| 72 | {"client-stream-recv", &testdata.ServerStreamingServerRPCSharedResultRecvCode}, |
| 73 | }}, |
| 74 | |
| 75 | // streaming payload |
| 76 | |
| 77 | {"client-streaming", testdata.ClientStreamingRPCDSL, []*sectionExpectation{ |
| 78 | {"server-stream-struct-type", &testdata.ClientStreamingServerStructCode}, |
| 79 | {"server-stream-send", &testdata.ClientStreamingServerSendCode}, |
| 80 | {"server-stream-recv", &testdata.ClientStreamingServerRecvCode}, |
| 81 | {"client-stream-struct-type", &testdata.ClientStreamingClientStructCode}, |
| 82 | {"client-stream-send", &testdata.ClientStreamingClientSendCode}, |
| 83 | {"client-stream-recv", &testdata.ClientStreamingClientRecvCode}, |
| 84 | }}, |
| 85 | {"client-streaming-no-result", testdata.ClientStreamingNoResultDSL, []*sectionExpectation{ |
| 86 | {"server-stream-send", nil}, |
| 87 | {"server-stream-close", &testdata.ClientStreamingServerNoResultCloseCode}, |
| 88 | {"client-stream-recv", nil}, |
| 89 | {"client-stream-close", &testdata.ClientStreamingClientNoResultCloseCode}, |
| 90 | }}, |
| 91 |
nothing calls this directly
no test coverage detected