Function startStandaloneSvr

server/server_test.go:45–65

(t *testing.T, ctx context.Context, opts ...ServerOption)

}

func startStandaloneSvr(t *testing.T, ctx context.Context, opts ...ServerOption) (*Server, string) {
	ln := getListener(t)
	defaultOpts := []ServerOption{
		WithHttpListener(ln),
		WithTubeFactoryBuilders(GetBuiltinTubeFactoryBuilder()),
		WithRuntimeFactoryBuilders(GetBuiltinRuntimeFactoryBuilder()),
	}
	s, err := NewServer(
		append(defaultOpts, opts...)...,
	)
	if err != nil {
		t.Fatal(err)
	}
	svrCtx, svrCancel := context.WithCancel(context.Background())
	go s.Run(svrCtx)
	go func() {
		<-ctx.Done()
		svrCancel()
	}()
	return s, ln.Addr().String()
}

func TestStandaloneBasicFunction(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())