Ensure IndexChannel and DatastreamChannel have constructor with callb…

…ackListeners (#27)
elastic · Apr 5, 2023 · 1198997 · 1198997
1 parent c073cb9
commit 1198997
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git 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
@@ -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, "*");