Function TestServerStreaming

http/codegen/streaming_test.go:34–212

(t *testing.T)

)

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

		// streaming result
		{"mixed-results", testdata.MixedResultsDSL, []*sectionExpectation{
			{"server-handler-init", &testdata.MixedResultsServerHandlerInitCode},
		}},
		{"streaming-result", testdata.StreamingResultDSL, []*sectionExpectation{
			{"server-handler-init", &testdata.StreamingResultServerHandlerInitCode},
			{"server-websocket-send", &testdata.StreamingResultServerStreamSendCode},
			{"server-websocket-close", &testdata.StreamingResultServerStreamCloseCode},
			{"server-websocket-set-view", nil},
		}},
		{"streaming-result-with-views", testdata.StreamingResultWithViewsDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultWithViewsServerStreamSendCode},
			{"server-websocket-close", &testdata.StreamingResultWithViewsServerStreamCloseCode},
			{"server-websocket-set-view", &testdata.StreamingResultWithViewsServerStreamSetViewCode},
		}},
		{"streaming-result-with-explicit-view", testdata.StreamingResultWithExplicitViewDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultWithExplicitViewServerStreamSendCode},
			{"server-websocket-set-view", nil},
		}},
		{"streaming-result-collection-with-views", testdata.StreamingResultCollectionWithViewsDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultCollectionWithViewsServerStreamSendCode},
			{"server-websocket-set-view", &testdata.StreamingResultCollectionWithViewsServerStreamSetViewCode},
		}},
		{"streaming-result-collection-with-explicit-view", testdata.StreamingResultCollectionWithExplicitViewDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultCollectionWithExplicitViewServerStreamSendCode},
			{"server-websocket-set-view", nil},
		}},
		{"streaming-result-primitive", testdata.StreamingResultPrimitiveDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultPrimitiveServerStreamSendCode},
			{"server-websocket-set-view", nil},
		}},
		{"streaming-result-primitive-array", testdata.StreamingResultPrimitiveArrayDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultPrimitiveArrayServerStreamSendCode},
		}},
		{"streaming-result-primitive-map", testdata.StreamingResultPrimitiveMapDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultPrimitiveMapServerStreamSendCode},
		}},
		{"streaming-result-user-type-array", testdata.StreamingResultUserTypeArrayDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultUserTypeArrayServerStreamSendCode},
		}},
		{"streaming-result-user-type-map", testdata.StreamingResultUserTypeMapDSL, []*sectionExpectation{
			{"server-websocket-send", &testdata.StreamingResultUserTypeMapServerStreamSendCode},
		}},
		{"streaming-result-no-payload", testdata.StreamingResultNoPayloadDSL, []*sectionExpectation{
			{"server-handler-init", &testdata.StreamingResultNoPayloadServerHandlerInitCode},
		}},

		// streaming payload

		{"streaming-payload", testdata.StreamingPayloadDSL, []*sectionExpectation{
			{"server-handler-init", &testdata.StreamingPayloadServerHandlerInitCode},