From 11989970035ce112c2ac9c401b92de41215d031f Mon Sep 17 00:00:00 2001
From: Martijn Laarman <Mpdreamz@gmail.com>
Date: Wed, 5 Apr 2023 13:29:14 +0200
Subject: [PATCH] Ensure IndexChannel and DatastreamChannel have constructor
 with callbackListeners (#27)

---
 .../DataStreams/DataStreamChannel.cs                       | 6 +++++-
 src/Elastic.Ingest.Elasticsearch/Indices/IndexChannel.cs   | 7 ++++++-
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/src/Elastic.Ingest.Elasticsearch/DataStreams/DataStreamChannel.cs b/src/Elastic.Ingest.Elasticsearch/DataStreams/DataStreamChannel.cs
index 2b35290..da2e6bd 100644
--- a/src/Elastic.Ingest.Elasticsearch/DataStreams/DataStreamChannel.cs
+++ b/src/Elastic.Ingest.Elasticsearch/DataStreams/DataStreamChannel.cs
@@ -5,6 +5,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using Elastic.Channels;
+using Elastic.Channels.Diagnostics;
 using Elastic.Ingest.Elasticsearch.Serialization;
 using Elastic.Ingest.Transport;
 
@@ -16,7 +17,10 @@ public class DataStreamChannel<TEvent> : ElasticsearchChannelBase<TEvent, DataSt
 		private readonly CreateOperation _fixedHeader;
 
 		/// <inheritdoc cref="DataStreamChannel{TEvent}"/>
-		public DataStreamChannel(DataStreamChannelOptions<TEvent> options) : base(options)
+		public DataStreamChannel(DataStreamChannelOptions<TEvent> options) : this(options, null) { }
+
+		/// <inheritdoc cref="DataStreamChannel{TEvent}"/>
+		public DataStreamChannel(DataStreamChannelOptions<TEvent> options, ICollection<IChannelCallbacks<TEvent, BulkResponse>>? callbackListeners) : base(options, callbackListeners)
 		{
 			var target = Options.DataStream.ToString();
 			_fixedHeader = new CreateOperation { Index = target };
diff --git a/src/Elastic.Ingest.Elasticsearch/Indices/IndexChannel.cs b/src/Elastic.Ingest.Elasticsearch/Indices/IndexChannel.cs
index d8f208b..f49786a 100644
--- a/src/Elastic.Ingest.Elasticsearch/Indices/IndexChannel.cs
+++ b/src/Elastic.Ingest.Elasticsearch/Indices/IndexChannel.cs
@@ -2,6 +2,8 @@
 // Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information
 using System;
+using System.Collections.Generic;
+using Elastic.Channels.Diagnostics;
 using Elastic.Ingest.Elasticsearch.DataStreams;
 using Elastic.Ingest.Elasticsearch.Serialization;
 using Elastic.Ingest.Transport;
@@ -14,7 +16,10 @@ namespace Elastic.Ingest.Elasticsearch.Indices
 	public class IndexChannel<TEvent> : ElasticsearchChannelBase<TEvent, IndexChannelOptions<TEvent>>
 	{
 		/// <inheritdoc cref="IndexChannel{TEvent}"/>
-		public IndexChannel(IndexChannelOptions<TEvent> options) : base(options)
+		public IndexChannel(IndexChannelOptions<TEvent> options) : this(options, null) { }
+
+		/// <inheritdoc cref="IndexChannel{TEvent}"/>
+		public IndexChannel(IndexChannelOptions<TEvent> options, ICollection<IChannelCallbacks<TEvent, BulkResponse>>? callbackListeners) : base(options, callbackListeners)
 		{
 			TemplateName = string.Format(Options.IndexFormat, "template");
 			TemplateWildcard = string.Format(Options.IndexFormat, "*");