log.Errorf("failed to send: %v", err)
				return err
			}
		} else {
			log.Errorf("failed to call tap request: %v", err)
			return err
		}
	}
	return nil
}

func (p *tapProxy) DeltaAggregatedResources(downstream DeltaDiscoveryStream) error {
	return fmt.Errorf("not implemented")