code: func (a *Airport) processArrivals() {
  	for {
  		arrival, ok := <-a.arrivalChan
  		if !ok {
  			a.log.Errorf("arrival channel closed")
  			return
  		}
  		switch arrival.GetChangeType() {
  		case datasync.Put:
  			fl := flight.Info{}
  			if err := arrival.GetValue(&fl); err != nil {
  				a.log.Errorf("failed to get value for arrival flight: %v", err)
  				continue
  			}
  			fl.Status = flight.Status_arrival
  			a.runwayChan <- fl
  		case datasync.Delete:
  			a.log.Debugf("arrival %s deleted\n", arrival.GetKey())
  		}
  	}
  }
docs: // Wait for arrivals. Incoming flights are set to 'arrival' status and sent to runway.