Name fixes. Also, factored out IAsyncEnumerable<T>().ToListAsync() into extensions so that both test styles can use it without taking an extra library dependency.

Author: dbarnett-netifi

RSocket.Core.Tests/Extensions.cs

@@ -27,5 +27,15 @@ static public IAsyncEnumerable<T> ToAsyncEnumerable<T>(this async_enumerable_dot
 				() => enumerator.Current,
 				() => enumerator.DisposeAsync());
 		});
+
+
+		static public async Task<List<T>> ToListAsync<T>(this IAsyncEnumerable<T> source)
+		{
+			var list = new List<T>();
+			var enumerator = source.GetAsyncEnumerator();
+			try { while (await enumerator.MoveNextAsync()) { list.Add(enumerator.Current); } }
+			finally { await enumerator.DisposeAsync(); }
+			return list;
+		}
 	}
 }

RSocket.Core.Tests/ServerAlternateProducerTests.cs

@@ -10,7 +10,7 @@
 namespace RSocket.Tests
 {
 	[TestClass]
-	public class ServerAlternateTests
+	public class ServerAlternateProducerTests
 	{
 		LoopbackTransport Loopback;
 		RSocketClient Client;
@@ -29,10 +29,8 @@ public async Task ServerRequestStreamTest()
 
 			var (data, metadata) = ("TEST DATA", "METADATA?_____");
 
-			var enumerator = StringClient.RequestStream(data, metadata).GetAsyncEnumerator();
-			var list = new List<string>();
-			try { while (await enumerator.MoveNextAsync()) { list.Add(enumerator.Current); } }     //This is basically ToList()
-			finally { enumerator.DisposeAsync().AsTask().Wait(); }
+			var list = await StringClient.RequestStream(data, metadata)
+				.ToListAsync();
 
 			Assert.AreEqual(3, list.Count, "Stream contents missing.");
 			list.ForEach(item => Assert.AreEqual(item, data, "Stream contents mismatch."));