Whitespace fix.

Author: electricessence

Open.ChannelExtensions.Tests/BasicTests.cs

@@ -136,6 +136,7 @@ public static async Task ReadAllConcurrentlyAsEnumerables()
 				{
 					// loop delay
 				}
+
 				Interlocked.Increment(ref total);
 			}
 		});

Open.ChannelExtensions.Tests/BatchTests.Memory.cs

@@ -47,6 +47,7 @@ await c.Reader
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			});
 	}
@@ -99,6 +100,7 @@ await c.Reader
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			});
 	}
@@ -142,6 +144,7 @@ public static async Task ForceBatchTest()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(500);
 		}));
 	}
@@ -190,6 +193,7 @@ public static async Task ForceBatchTest2()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(500);
 		}));
 	}
@@ -227,6 +231,7 @@ public static async Task TimeoutTest0()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(100);
 		}));
 	}
@@ -249,6 +254,7 @@ public static async Task TimeoutTest1()
 			{
 				c.Writer.TryWrite(i);
 			}
+
 			c.Writer.Complete();
 		});
 
@@ -272,6 +278,7 @@ public static async Task TimeoutTest1()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(100);
 		}));
 	}
@@ -395,8 +402,10 @@ public static async Task ReadBatchWithTimeoutEnumerableBakedIn()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			i++;
 		}
+
 		Assert.Equal(3, i);
 		await c.Reader.Completion; // Propagate possible failure
 	}

Open.ChannelExtensions.Tests/BatchTests.Queue.cs

@@ -46,6 +46,7 @@ await c.Reader
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			});
 	}
@@ -98,6 +99,7 @@ await c.Reader
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			});
 	}
@@ -154,6 +156,7 @@ public static async Task ForceBatchTest()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(500);
 		}));
 	}
@@ -210,6 +213,7 @@ public static async Task ForceBatchTest2()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(500);
 		}));
 	}
@@ -245,6 +249,7 @@ public static async Task TimeoutTest0()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(100);
 		}));
 	}
@@ -267,6 +272,7 @@ public static async Task TimeoutTest1()
 			{
 				c.Writer.TryWrite(i);
 			}
+
 			c.Writer.Complete();
 		});
 
@@ -287,6 +293,7 @@ public static async Task TimeoutTest1()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(100);
 		}));
 	}
@@ -412,8 +419,10 @@ public static async Task ReadBatchWithTimeoutEnumerableBakedIn()
 				default:
 					throw new Exception("Shouldn't arrive here. Got batch: " + string.Join(',', batch.Select(item => item)));
 			}
+
 			i++;
 		}
+
 		Assert.Equal(3, i);
 		await c.Reader.Completion; // Propagate possible failure
 	}

Open.ChannelExtensions.Tests/BatchTests.cs

@@ -44,6 +44,7 @@ await c.Reader
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			});
 	}
@@ -93,6 +94,7 @@ await c.Reader
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			});
 	}
@@ -133,6 +135,7 @@ public static async Task ForceBatchTest()
 					default:
 						throw new Exception("Shouldn't arrive here.");
 				}
+
 				await Task.Delay(500);
 			}));
 	}
@@ -178,6 +181,7 @@ public static async Task ForceBatchTest2()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(500);
 		}));
 	}
@@ -213,6 +217,7 @@ public static async Task TimeoutTest0()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(100);
 		}));
 	}
@@ -235,6 +240,7 @@ public static async Task TimeoutTest1()
 			{
 				c.Writer.TryWrite(i);
 			}
+
 			c.Writer.Complete();
 		});
 
@@ -255,6 +261,7 @@ public static async Task TimeoutTest1()
 				default:
 					throw new Exception("Shouldn't arrive here.");
 			}
+
 			await Task.Delay(100);
 		}));
 	}
@@ -373,8 +380,10 @@ public static async Task ReadBatchWithTimeoutEnumerableBakedIn()
 				default:
 					throw new Exception("Shouldn't arrive here. Got batch: " + string.Join(',', batch.Select(item => item)));
 			}
+
 			i++;
 		}
+
 		Assert.Equal(3, i);
 		await c.Reader.Completion; // Propagate possible failure
 	}

Open.ChannelExtensions.Tests/CancellationTests.cs

@@ -20,6 +20,7 @@ await range
 						Interlocked.Increment(ref count);
 						tokenSource.Cancel();
 					}
+
 					token.ThrowIfCancellationRequested();
 				});
 		}
@@ -52,6 +53,7 @@ await range
 						Interlocked.Increment(ref count);
 						tokenSource.Cancel();
 					}
+
 					token.ThrowIfCancellationRequested();
 				});
 		}

Open.ChannelExtensions/Extensions.Read.cs

@@ -392,6 +392,7 @@ public static async ValueTask ReadAllAsEnumerablesAsync<T>(this ChannelReader<T>
 			{
 				await receiver(reader.ReadAvailable(cancellationToken)).ConfigureAwait(false);
 			}
+
 			return;
 		}
 

Open.ChannelExtensions/Extensions.Write.cs

@@ -43,6 +43,7 @@ await target
 				count++;
 				next = target.WriteAsync(value, cancellationToken);
 			}
+
 			await next.ConfigureAwait(false);
 			return count;
 		}
@@ -54,6 +55,7 @@ await target
 				target.TryComplete(ex);
 				complete = false;
 			}
+
 			throw;
 		}
 		finally
@@ -272,6 +274,7 @@ public static async ValueTask<long> WriteAllLines(
 				count++;
 				next = target.WriteAsync(line, cancellationToken);
 			}
+
 			await next.ConfigureAwait(false);
 			if (more) cancellationToken.ThrowIfCancellationRequested();
 			return count;
@@ -284,6 +287,7 @@ public static async ValueTask<long> WriteAllLines(
 				target.TryComplete(ex);
 				complete = false;
 			}
+
 			throw;
 		}
 		finally
@@ -345,6 +349,7 @@ await target
 				count++;
 				next = target.WriteAsync(value, cancellationToken);
 			}
+
 			await next.ConfigureAwait(false);
 			return count;
 		}
@@ -356,6 +361,7 @@ await target
 				target.TryComplete(ex);
 				complete = false;
 			}
+
 			throw;
 		}
 		finally

Open.ChannelExtensions/Open.ChannelExtensions.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<PropertyGroup>
-		<TargetFrameworks>netstandard2.0; netstandard2.1; net6.0; net8.0</TargetFrameworks>
+		<TargetFrameworks>netstandard2.0; netstandard2.1; net6.0; net8.0; net9.0;</TargetFrameworks>
 		<LangVersion>latest</LangVersion>
 		<EnableNETAnalyzers>true</EnableNETAnalyzers>
 		<AnalysisMode>AllEnabledByDefault</AnalysisMode>