Method Start

rivershared/startstop/start_stop_test.go:28–50

(ctx context.Context)

}

func (s *sampleService) Start(ctx context.Context) error {
	ctx, shouldStart, started, stopped := s.StartInit(ctx)
	if !shouldStart {
		return nil
	}

	if s.startErr != nil {
		stopped()
		return s.startErr
	}

	go func() {
		// Set this before confirming started.
		s.state = true

		started()
		defer stopped()

		<-ctx.Done()
	}()

	return nil
}

func testService(t *testing.T, newService func(t *testing.T) serviceWithStopped) {
	t.Helper()