in src/Elastic.Ingest.Apm/ApmChannel.cs [37:55]
protected override List<(IIntakeObject, IntakeErrorItem)> Zip(EventIntakeResponse response, IReadOnlyCollection<IIntakeObject> page) =>
_emptyZip;
private readonly List<(IIntakeObject, IntakeErrorItem)> _emptyZip = new();
/// <inheritdoc cref="ResponseItemsBufferedChannelBase{TChannelOptions,TEvent,TResponse,TBulkResponseItem}.RetryEvent"/>
protected override bool RetryEvent((IIntakeObject, IntakeErrorItem) @event) => false;
/// <inheritdoc cref="ResponseItemsBufferedChannelBase{TChannelOptions,TEvent,TResponse,TBulkResponseItem}.RejectEvent"/>
protected override bool RejectEvent((IIntakeObject, IntakeErrorItem) @event) => false;
/// <inheritdoc cref="BufferedChannelBase{TChannelOptions,TEvent,TResponse}.ExportAsync"/>
protected override Task<EventIntakeResponse> ExportAsync(ITransport transport, ArraySegment<IIntakeObject> page, CancellationToken ctx = default) =>
transport.RequestAsync<EventIntakeResponse>(new EndpointPath(HttpMethod.POST, "/intake/v2/events"),
PostData.StreamHandler(page,
(_, _) =>
{
/* NOT USED */
},