serve.go

func (s *sub) serve(ctx context.Context, checkFrequency int) {
  clock := time.NewTicker(time.Duration(checkFrequency) * time.Second)
  type fetchResult struct {
    fetched Item
    err     error
  }
  fetchDone := make(chan fetchResult, 1)
  
  for {
    select {
    // Clock that triggers the fetch
    case <-clock.C:
      go func() {
	fetched, err := s.fetcher.Fetch()
	fetchDone <- fetchResult{fetched, err}
      }()
    // Case where the fetch result is
    // Ready to be consumed
    case result := <-fetchDone:
      fetched := result.fetched
      if result.err != nil {
        log.Println("Fetch error: %v \n Waiting the next iteration", result.err.Error())
	break
      }
      s.updates <-fetched
    // Case where we need to close the server
    case <-ctx.Done():
      return
    }
  }
}