diff --git a/src/Wolfgang.Etl.Abstractions/ExtractorBase.cs b/src/Wolfgang.Etl.Abstractions/ExtractorBase.cs
index a09dc64..ce9b479 100644
--- a/src/Wolfgang.Etl.Abstractions/ExtractorBase.cs
+++ b/src/Wolfgang.Etl.Abstractions/ExtractorBase.cs
@@ -164,13 +164,7 @@ public int SkipItemCount
- ///
- /// Asynchronously extracts data of type TSource from a source.
- ///
- ///
- /// IAsyncEnumerable<TSource>
- /// The result may be an empty sequence if no data is available or if the extraction fails.
- ///
+ ///
public virtual IAsyncEnumerable ExtractAsync()
{
return ExtractWorkerAsync(CancellationToken.None);
@@ -178,18 +172,7 @@ public virtual IAsyncEnumerable ExtractAsync()
- ///
- /// Asynchronously extracts data of type TSource from a source.
- ///
- /// A CancellationToken to observe while waiting for the task to complete.
- ///
- /// IAsyncEnumerable<TSource>
- /// The result may be an empty sequence if no data is available or if the extraction fails.
- ///
- ///
- /// The extractor should be able to handle cancellation requests gracefully.
- /// If the caller doesn't plan on cancelling the extraction, they can pass CancellationToken.None.
- ///
+ ///
public virtual IAsyncEnumerable ExtractAsync(CancellationToken token)
{
return ExtractWorkerAsync(token);
@@ -197,15 +180,7 @@ public virtual IAsyncEnumerable ExtractAsync(CancellationToken token)
- ///
- /// Asynchronously extracts data of type TSource from a source.
- ///
- /// A provider for progress updates.
- ///
- /// IAsyncEnumerable<TSource>
- /// The result may be an empty sequence if no data is available or if the extraction fails.
- ///
- /// The value of progress is null
+ ///
public virtual IAsyncEnumerable ExtractAsync(IProgress progress)
{
#if NET6_0_OR_GREATER
@@ -224,20 +199,7 @@ public virtual IAsyncEnumerable ExtractAsync(IProgress progr
- ///
- /// Asynchronously extracts data of type TSource from a source.
- ///
- /// A provider for progress updates.
- /// A CancellationToken to observe while waiting for the task to complete.
- ///
- /// IAsyncEnumerable<TSource>
- /// The result may be an empty sequence if no data is available or if the extraction fails.
- ///
- ///
- /// The extractor should be able to handle cancellation requests gracefully.
- /// If the caller doesn't plan on cancelling the extraction, they can pass CancellationToken.None.
- ///
- /// The value of progress is null
+ ///
public virtual IAsyncEnumerable ExtractAsync(IProgress progress, CancellationToken token)
{
#if NET6_0_OR_GREATER
diff --git a/src/Wolfgang.Etl.Abstractions/LoaderBase.cs b/src/Wolfgang.Etl.Abstractions/LoaderBase.cs
index 4a88db6..3d2bc84 100644
--- a/src/Wolfgang.Etl.Abstractions/LoaderBase.cs
+++ b/src/Wolfgang.Etl.Abstractions/LoaderBase.cs
@@ -137,15 +137,7 @@ public int SkipItemCount
- ///
- /// Asynchronously loads data of type TDestination into the target destination.
- ///
- /// The items to be loaded to the destination.
- /// A task representing the asynchronous operation.
- ///
- /// Items may be an empty sequence if no data is available or if the loading fails.
- ///
- /// Argument items is null
+ ///
public virtual Task LoadAsync(IAsyncEnumerable items)
{
#if NET6_0_OR_GREATER
@@ -163,16 +155,7 @@ public virtual Task LoadAsync(IAsyncEnumerable items)
- ///
- /// Asynchronously loads data of type TDestination into the target destination.
- ///
- /// The items to be loaded to the destination.
- /// A CancellationToken to observe while waiting for the task to complete.
- /// A task representing the asynchronous operation.
- ///
- /// Items may be an empty sequence if no data is available or if the loading fails.
- ///
- /// Argument items is null
+ ///
public virtual Task LoadAsync(IAsyncEnumerable items, CancellationToken token)
{
#if NET6_0_OR_GREATER
@@ -190,17 +173,7 @@ public virtual Task LoadAsync(IAsyncEnumerable items, Cancellation
- ///
- /// Asynchronously loads data of type TDestination into the target destination.
- ///
- /// The items to be loaded to the destination.
- /// A provider for progress updates.
- /// A task representing the asynchronous operation.
- ///
- /// Items may be an empty sequence if no data is available or if the loading fails.
- ///
- /// Argument items is null
- /// Argument progress is null
+ ///
public virtual Task LoadAsync(IAsyncEnumerable items, IProgress progress)
{
#if NET6_0_OR_GREATER
@@ -224,18 +197,7 @@ public virtual Task LoadAsync(IAsyncEnumerable items, IProgress
- /// Asynchronously loads data of type TDestination into the target destination.
- ///
- /// The items to be loaded to the destination.
- /// A provider for progress updates.
- /// A CancellationToken to observe while waiting for the task to complete.
- /// A task representing the asynchronous operation.
- ///
- /// Items may be an empty sequence if no data is available or if the loading fails.
- ///
- /// Argument items is null
- /// Argument progress is null
+ ///
public virtual Task LoadAsync(IAsyncEnumerable items, IProgress progress, CancellationToken token)
{
#if NET6_0_OR_GREATER
diff --git a/src/Wolfgang.Etl.Abstractions/TransformerBase.cs b/src/Wolfgang.Etl.Abstractions/TransformerBase.cs
index 7223f45..989ec8c 100644
--- a/src/Wolfgang.Etl.Abstractions/TransformerBase.cs
+++ b/src/Wolfgang.Etl.Abstractions/TransformerBase.cs
@@ -140,15 +140,7 @@ public int SkipItemCount
- ///
- /// Asynchronously transforms data of type TSource to TDestination
- ///
- /// IAsyncEnumerable<TSource> - A list of 0 or more items to be transformed
- ///
- /// IAsyncEnumerable<TDestination>
- /// The result may be an empty sequence if no data is available or if the transformation fails.
- ///
- /// The value of items is null
+ ///
public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable items)
{
#if NET6_0_OR_GREATER
@@ -166,19 +158,7 @@ public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable
- /// Asynchronously transforms data of type TSource to TDestination
- ///
- /// IAsyncEnumerable<TSource> - A list of 0 or more items to be transformed
- /// A CancellationToken to observe while waiting for the task to complete.
- ///
- /// IAsyncEnumerable<TDestination> - A list of 0 or more transformed items
- ///
- ///
- /// The transformer should be able to handle cancellation requests gracefully.
- /// If the caller doesn't plan on cancelling the transformation, they can pass CancellationToken.None.
- ///
- /// The value of items is null
+ ///
public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable items, CancellationToken token)
{
#if NET6_0_OR_GREATER
@@ -196,16 +176,7 @@ public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable
- /// Asynchronously transforms data of type TSource to TDestination
- ///
- /// IAsyncEnumerable<TSource> - A list of 0 or more items to be transformed
- /// A provider for progress updates.
- ///
- /// IAsyncEnumerable<TDestination> - The result may be an empty sequence if no data is available or if the transformation fails.
- ///
- /// The value of items is null
- /// The value of progress is null
+ ///
public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable items, IProgress progress)
{
#if NET6_0_OR_GREATER
@@ -229,21 +200,7 @@ public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable
- /// Asynchronously transforms data of type TSource to TDestination
- ///
- /// IAsyncEnumerable<TSource> - A list of 0 or more items to be transformed
- /// A provider for progress updates.
- /// A CancellationToken to observe while waiting for the task to complete.
- ///
- /// IAsyncEnumerable<TDestination> - The result may be an empty sequence if no data is available or if the transformation fails.
- ///
- ///
- /// The transformer should be able to handle cancellation requests gracefully.
- /// If the caller doesn't plan on cancelling the transformation, they can pass CancellationToken.None.
- ///
- /// The value of items is null
- /// The value of progress is null
+ ///
public virtual IAsyncEnumerable TransformAsync(IAsyncEnumerable items, IProgress progress, CancellationToken token)
{
#if NET6_0_OR_GREATER