Spelling fixes.

Author: electricessence

Open.ChannelExtensions/BatchingChannelReader.cs

@@ -39,7 +39,7 @@ protected BatchingChannelReader(
 	Timer? _timer;
 
 	/// <summary>
-	/// Specifies a timeout by which a batch will be emmited there is at least one item but has been waiting
+	/// Specifies a timeout by which a batch will be emitted there is at least one item but has been waiting
 	/// for longer than the timeout value.
 	/// </summary>
 	/// <param name="millisecondsTimeout">
@@ -151,7 +151,7 @@ protected override bool TryPipeItems(bool flush)
 			{
 				if (c is null)
 				{
-					newBatch = true; // a new batch could start but not be emmited.
+					newBatch = true; // a new batch could start but not be emitted.
 					_batch = c = CreateBatch(_batchSize);
 					AddBatchItem(c, item);
 				}
@@ -195,7 +195,7 @@ void Emit(ref TBatch? c)
 			{
 				_batch = null;
 				newBatch = false;
-				if (!batched) TryUpdateTimer(Timeout.Infinite); // Since we're emmitting one, let's ensure the timeout is cancelled.
+				if (!batched) TryUpdateTimer(Timeout.Infinite); // Since we're emitting one, let's ensure the timeout is cancelled.
 				batched = Buffer!.Writer.TryWrite(c!);
 				Debug.Assert(batched);
 				c = null;

Open.ChannelExtensions/Extensions.Read.cs

@@ -423,7 +423,7 @@ public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
 		CancellationToken cancellationToken,
 		Func<T, long, ValueTask> receiver,
@@ -480,7 +480,7 @@ public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, T
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		CancellationToken cancellationToken,
 		Func<TRead, long, ValueTask> receiver,
@@ -532,7 +532,7 @@ public static ValueTask<long> TaskReadAllAsync<TWrite, TRead>(this Channel<TWrit
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> TaskReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		CancellationToken cancellationToken,
 		Func<TRead, long, Task> receiver,
@@ -581,7 +581,7 @@ public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAllAsync<T>(this ChannelReader<T> reader,
 		CancellationToken cancellationToken,
 		Func<T, ValueTask> receiver,
@@ -630,7 +630,7 @@ public static ValueTask<long> TaskReadAllAsync<T>(this ChannelReader<T> reader,
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> TaskReadAllAsync<T>(this ChannelReader<T> reader,
 		CancellationToken cancellationToken,
 		Func<T, Task> receiver,
@@ -682,7 +682,7 @@ public static ValueTask<long> TaskReadAllAsync<TWrite, TRead>(this Channel<TWrit
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> TaskReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		CancellationToken cancellationToken,
 		Func<TRead, Task> receiver,
@@ -740,7 +740,7 @@ public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, T
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		CancellationToken cancellationToken,
 		Func<TRead, ValueTask> receiver,
@@ -753,7 +753,7 @@ public static ValueTask<long> ReadAllAsync<TWrite, TRead>(this Channel<TWrite, T
 	/// <typeparam name="T">The item type.</typeparam>
 	/// <param name="reader">The channel reader to read from.</param>
 	/// <param name="receiver">The receiver function.</param>
-	/// <param name="deferredExecution">If true, calls await Task.Yield() before writreadinging.</param>
+	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <param name="cancellationToken">An optional cancellation token.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
@@ -783,7 +783,7 @@ public static ValueTask<long> ReadAll<T>(this ChannelReader<T> reader,
 	/// <param name="reader">The channel reader to read from.</param>
 	/// <param name="receiver">The receiver function.</param>
 	/// <param name="cancellationToken">The cancellation token.</param>
-	/// <param name="deferredExecution">If true, calls await Task.Yield() before writreadinging.</param>
+	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
 	public static ValueTask<long> ReadAll<T>(this ChannelReader<T> reader,
@@ -799,10 +799,10 @@ public static ValueTask<long> ReadAll<T>(this ChannelReader<T> reader,
 	/// <param name="reader">The channel reader to read from.</param>
 	/// <param name="cancellationToken">The cancellation token.</param>
 	/// <param name="receiver">The receiver function.</param>
-	/// <param name="deferredExecution">If true, calls await Task.Yield() before writreadinging.</param>
+	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAll<T>(this ChannelReader<T> reader,
 		CancellationToken cancellationToken,
 		Action<T, long> receiver,
@@ -860,7 +860,7 @@ public static ValueTask<long> ReadAll<TWrite, TRead>(this Channel<TWrite, TRead>
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAll<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		CancellationToken cancellationToken,
 		Action<TRead, long> receiver,
@@ -921,7 +921,7 @@ public static ValueTask<long> ReadAll<T>(this ChannelReader<T> reader,
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAll<T>(this ChannelReader<T> reader,
 		CancellationToken cancellationToken,
 		Action<T> receiver,
@@ -978,7 +978,7 @@ public static ValueTask<long> ReadAll<TWrite, TRead>(this Channel<TWrite, TRead>
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.
 	/// The count should be ignored if the number of iterations could exceed the max value of long.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static ValueTask<long> ReadAll<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		CancellationToken cancellationToken,
 		Action<TRead> receiver,
@@ -1020,7 +1020,7 @@ public static ValueTask<long> ReadAllAsLines(this ChannelReader<string> reader,
 	/// </summary>
 	/// <typeparam name="T">The item type.</typeparam>
 	/// <param name="channel">The channel to read from.</param>
-	/// <param name="receiver">The TextWriter to recieve the lines.</param>
+	/// <param name="receiver">The TextWriter to receive the lines.</param>
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <param name="cancellationToken">An optional cancellation token.</param>
 	/// <returns>The count of items read after the reader has completed.
@@ -1041,7 +1041,7 @@ public static ValueTask<long> ReadAllAsLines<T>(this Channel<T, string> channel,
 	/// </summary>
 	/// <typeparam name="T">The item type.</typeparam>
 	/// <param name="channel">The channel to read from.</param>
-	/// <param name="receiver">The TextWriter to recieve the lines.</param>
+	/// <param name="receiver">The TextWriter to receive the lines.</param>
 	/// <param name="cancellationToken">An optional cancellation token.</param>
 	/// <param name="deferredExecution">If true, calls await Task.Yield() before reading.</param>
 	/// <returns>The count of items read after the reader has completed.

Open.ChannelExtensions/Extensions.ReadConcurrently.cs

@@ -79,7 +79,7 @@ async Task<long> Read()
 	/// <param name="cancellationToken">The cancellation token.</param>
 	/// <param name="receiver">The async receiver function.</param>
 	/// <returns>A task that completes when no more reading is to be done.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static Task<long> ReadAllConcurrentlyAsync<T>(this ChannelReader<T> reader,
 		int maxConcurrency,
 		CancellationToken cancellationToken,
@@ -132,7 +132,7 @@ public static Task<long> ReadAllConcurrentlyAsync<TWrite, TRead>(this Channel<TW
 	/// <param name="cancellationToken">The cancellation token.</param>
 	/// <param name="receiver">The async receiver function.</param>
 	/// <returns>A task that completes when no more reading is to be done.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static Task<long> ReadAllConcurrentlyAsync<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		int maxConcurrency,
 		CancellationToken cancellationToken,
@@ -190,7 +190,7 @@ public static Task<long> ReadAllConcurrently<T>(this ChannelReader<T> reader,
 	/// <param name="cancellationToken">The cancellation token.</param>
 	/// <param name="receiver">The receiver function.</param>
 	/// <returns>A task that completes when no more reading is to be done.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static Task<long> ReadAllConcurrently<T>(this ChannelReader<T> reader,
 		int maxConcurrency,
 		CancellationToken cancellationToken,
@@ -228,7 +228,7 @@ public static Task<long> ReadAllConcurrently<TWrite, TRead>(this Channel<TWrite,
 	/// <param name="cancellationToken">The cancellation token.</param>
 	/// <param name="receiver">The receiver function.</param>
 	/// <returns>A task that completes when no more reading is to be done.</returns>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static Task<long> ReadAllConcurrently<TWrite, TRead>(this Channel<TWrite, TRead> channel,
 		int maxConcurrency,
 		CancellationToken cancellationToken,
@@ -300,7 +300,7 @@ async Task Read()
 	}
 
 	/// <inheritdoc cref="ReadAllAsEnumerablesAsync{T}(ChannelReader{T}, Func{IEnumerable{T}, ValueTask}, bool, CancellationToken)"/>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static Task ReadAllConcurrentlyAsEnumerablesAsync<T>(this ChannelReader<T> reader,
 		int maxConcurrency,
 		CancellationToken cancellationToken,
@@ -327,7 +327,7 @@ public static Task ReadAllConcurrentlyAsEnumerables<T>(this ChannelReader<T> rea
 	}
 
 	/// <inheritdoc cref="ReadAllAsEnumerablesAsync{T}(ChannelReader{T}, Func{IEnumerable{T}, ValueTask}, bool, CancellationToken)"/>
-	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convience.")]
+	[SuppressMessage("Design", "CA1068:CancellationToken parameters must come last", Justification = "Provided for aesthetic convenience.")]
 	public static Task ReadAllConcurrentlyAsEnumerables<T>(this ChannelReader<T> reader,
 		int maxConcurrency,
 		CancellationToken cancellationToken,

Open.ChannelExtensions/Extensions.Transform.cs

@@ -41,7 +41,7 @@ public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationTo
 	/// <typeparam name="TResult">The output type of the transform.</typeparam>
 	/// <param name="source">The source channel reader.</param>
 	/// <param name="transform">The transform function.</param>
-	/// <returns>A channel reader representing the tranformed results.</returns>
+	/// <returns>A channel reader representing the transformed results.</returns>
 	public static ChannelReader<TResult> Transform<T, TResult>(this ChannelReader<T> source, Func<T, TResult> transform)
 		=> new TransformingChannelReader<T, TResult>(source, transform);
 
@@ -53,7 +53,7 @@ public static ChannelReader<TResult> Transform<T, TResult>(this ChannelReader<T>
 	/// <typeparam name="TResult">Specifies the type of data that may be read from the channel.</typeparam>
 	/// <param name="source">The source channel reader.</param>
 	/// <param name="transform">The transform function.</param>
-	/// <returns>A channel reader representing the tranformed results.</returns>
+	/// <returns>A channel reader representing the transformed results.</returns>
 	public static TransformChannel<TWrite, TRead, TResult> Transform<TWrite, TRead, TResult>(this Channel<TWrite, TRead> source, Func<TRead, TResult> transform)
 		=> new(source, transform);
 
@@ -64,7 +64,7 @@ public static TransformChannel<TWrite, TRead, TResult> Transform<TWrite, TRead,
 	/// <typeparam name="TResult">Specifies the type of data that may be read from the channel.</typeparam>
 	/// <param name="source">The source channel reader.</param>
 	/// <param name="transform">The transform function.</param>
-	/// <returns>A channel reader representing the tranformed results.</returns>
+	/// <returns>A channel reader representing the transformed results.</returns>
 	public static TransformChannel<T, TResult> Transform<T, TResult>(this Channel<T> source, Func<T, TResult> transform)
 		=> new(source, transform);
 }