Function TestErrStop

rivershared/startstop/start_stop_test.go:189–216

(t *testing.T)

}

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

	var workCtx context.Context

	startStop := StartStopFunc(func(ctx context.Context, shouldStart bool, started, stopped func()) error {
		if !shouldStart {
			return nil
		}

		workCtx = ctx //nolint:fatcontext

		go func() {
			started()
			defer stopped()
			<-ctx.Done()
		}()

		return nil
	})

	ctx := context.Background()

	require.NoError(t, startStop.Start(ctx))
	<-startStop.Started()
	startStop.Stop()
	require.ErrorIs(t, context.Cause(workCtx), ErrStop)
}

// BaseStartStop tests that need specific internal implementation (like ones we
// can add to sampleService) to be able to verify.