Function TestStopAllParallel

rivershared/startstop/start_stop_test.go:549–601

(t *testing.T)

}

func TestStopAllParallel(t *testing.T) {
	t.Parallel()

	ctx := context.Background()

	t.Run("Started", func(t *testing.T) {
		t.Parallel()

		var (
			service1 = &sampleService{}
			service2 = &sampleService{}
			service3 = &sampleService{}
		)

		require.NoError(t, service1.Start(ctx))
		require.NoError(t, service2.Start(ctx))
		require.NoError(t, service3.Start(ctx))

		var (
			stopped1 = service1.Stopped()
			stopped2 = service2.Stopped()
			stopped3 = service3.Stopped()
		)

		StopAllParallel(
			service1,
			service2,
			service3,
		)

		riversharedtest.WaitOrTimeout(t, stopped1)
		riversharedtest.WaitOrTimeout(t, stopped2)
		riversharedtest.WaitOrTimeout(t, stopped3)
	})

	// We can't use the stopped channels in this case because they're only
	// initiated when a service is started.
	t.Run("NotStarted", func(t *testing.T) {
		t.Parallel()

		var (
			service1 = &sampleService{}
			service2 = &sampleService{}
			service3 = &sampleService{}
		)

		StopAllParallel(
			service1,
			service2,
			service3,
		)
	})
}

func TestWaitAllStarted(t *testing.T) {
	t.Parallel()