Function TestClientStreaming

http/codegen/streaming_test.go:214–395

(t *testing.T)

}

func TestClientStreaming(t *testing.T) {
	cases := []*testCase{
		{"client-mixed-endpoints", testdata.StreamingResultDSL, []*sectionExpectation{
			{"client-websocket-conn-configurer-struct", &testdata.MixedEndpointsConnConfigurerStructCode},
			{"client-websocket-conn-configurer-struct-init", &testdata.MixedEndpointsConnConfigurerInitCode},
		}},

		// streaming result
		{"client-streaming-result", testdata.StreamingResultDSL, []*sectionExpectation{
			{"client-endpoint-init", &testdata.StreamingResultClientEndpointCode},
			{"client-websocket-recv", &testdata.StreamingResultClientStreamRecvCode},
			{"client-websocket-close", nil},
			{"client-websocket-set-view", nil},
		}},
		{"client-streaming-result-with-views", testdata.StreamingResultWithViewsDSL, []*sectionExpectation{
			{"client-endpoint-init", &testdata.StreamingResultWithViewsClientEndpointCode},
			{"client-websocket-recv", &testdata.StreamingResultWithViewsClientStreamRecvCode},
			{"client-websocket-close", nil},
			{"client-websocket-set-view", &testdata.StreamingResultWithViewsClientStreamSetViewCode},
		}},
		{"client-streaming-result-with-explicit-view", testdata.StreamingResultWithExplicitViewDSL, []*sectionExpectation{
			{"client-endpoint-init", &testdata.StreamingResultWithExplicitViewClientEndpointCode},
			{"client-websocket-recv", &testdata.StreamingResultWithExplicitViewClientStreamRecvCode},
			{"client-websocket-set-view", nil},
		}},
		{"client-streaming-result-collection-with-views", testdata.StreamingResultCollectionWithViewsDSL, []*sectionExpectation{
			{"client-websocket-recv", &testdata.StreamingResultCollectionWithViewsClientStreamRecvCode},
			{"client-websocket-set-view", &testdata.StreamingResultCollectionWithViewsClientStreamSetViewCode},
		}},
		{"client-streaming-result-collection-with-explicit-view", testdata.StreamingResultCollectionWithExplicitViewDSL, []*sectionExpectation{
			{"client-endpoint-init", &testdata.StreamingResultCollectionWithExplicitViewClientEndpointCode},
			{"client-websocket-recv", &testdata.StreamingResultCollectionWithExplicitViewClientStreamRecvCode},
			{"client-websocket-set-view", nil},
		}},
		{"client-streaming-result-primitive", testdata.StreamingResultPrimitiveDSL, []*sectionExpectation{
			{"client-websocket-recv", &testdata.StreamingResultPrimitiveClientStreamRecvCode},
			{"client-websocket-set-view", nil},
		}},
		{"client-streaming-result-primitive-array", testdata.StreamingResultPrimitiveArrayDSL, []*sectionExpectation{
			{"client-websocket-recv", &testdata.StreamingResultPrimitiveArrayClientStreamRecvCode},
		}},
		{"client-streaming-result-primitive-map", testdata.StreamingResultPrimitiveMapDSL, []*sectionExpectation{
			{"client-websocket-recv", &testdata.StreamingResultPrimitiveMapClientStreamRecvCode},
		}},
		{"client-streaming-result-user-type-array", testdata.StreamingResultUserTypeArrayDSL, []*sectionExpectation{
			{"client-websocket-recv", &testdata.StreamingResultUserTypeArrayClientStreamRecvCode},
		}},
		{"client-streaming-result-user-type-map", testdata.StreamingResultUserTypeMapDSL, []*sectionExpectation{
			{"client-websocket-recv", &testdata.StreamingResultUserTypeMapClientStreamRecvCode},
		}},
		{"client-streaming-result-no-payload", testdata.StreamingResultNoPayloadDSL, []*sectionExpectation{
			{"client-endpoint-init", &testdata.StreamingResultNoPayloadClientEndpointCode},
		}},

		// streaming payload

		{"client-streaming-payload", testdata.StreamingPayloadDSL, []*sectionExpectation{
			{"client-endpoint-init", &testdata.StreamingPayloadClientEndpointCode},