Add GetFieldAsync tests for TextReader and Stream. Fixes #144

Author: bgrainger

src/AdoNet.Specification.Tests/DataReaderTestBase.cs

@@ -733,6 +733,18 @@ public virtual void GetFieldValue_for_TextReader()
 			Assert.Equal("1", textReader.ReadToEnd());
 		}
 
+		[Fact]
+		public virtual async Task GetFieldValueAsync_for_TextReader()
+		{
+			using var connection = CreateOpenConnection();
+			using var command = connection.CreateCommand();
+			command.CommandText = Fixture.CreateSelectSql(DbType.String, ValueKind.One);
+			using var reader = await command.ExecuteReaderAsync();
+			await reader.ReadAsync();
+			using var textReader = await reader.GetFieldValueAsync<TextReader>(0);
+			Assert.Equal("1", textReader.ReadToEnd());
+		}
+
 		[Fact]
 		public virtual void GetFieldValue_for_TextReader_throws_for_null_String()
 		{
@@ -744,6 +756,17 @@ public virtual void GetFieldValue_for_TextReader_throws_for_null_String()
 			Assert.Throws<InvalidCastException>(() => reader.GetFieldValue<TextReader>(0));
 		}
 
+		[Fact]
+		public virtual async Task GetFieldValueAsync_for_TextReader_throws_for_null_String()
+		{
+			using var connection = CreateOpenConnection();
+			using var command = connection.CreateCommand();
+			command.CommandText = Fixture.CreateSelectSql(DbType.String, ValueKind.Null);
+			using var reader = await command.ExecuteReaderAsync();
+			await reader.ReadAsync();
+			await Assert.ThrowsAsync<InvalidCastException>(async () => await reader.GetFieldValueAsync<TextReader>(0));
+		}
+
 		[Fact]
 		public virtual void GetFieldValue_for_Stream()
 		{
@@ -753,7 +776,19 @@ public virtual void GetFieldValue_for_Stream()
 			using var reader = command.ExecuteReader();
 			reader.Read();
 			using var stream = reader.GetFieldValue<Stream>(0);
-			Assert.Equal(1, stream.ReadByte());
+			Assert.Equal(0x11, stream.ReadByte());
+		}
+
+		[Fact]
+		public virtual async Task GetFieldValueAsync_for_Stream()
+		{
+			using var connection = CreateOpenConnection();
+			using var command = connection.CreateCommand();
+			command.CommandText = Fixture.CreateSelectSql(DbType.Binary, ValueKind.One);
+			using var reader = await command.ExecuteReaderAsync();
+			await reader.ReadAsync();
+			using var stream = await reader.GetFieldValueAsync<Stream>(0);
+			Assert.Equal(0x11, stream.ReadByte());
 		}
 
 		[Fact]
@@ -767,6 +802,17 @@ public virtual void GetFieldValue_for_Stream_throws_for_null_Binary()
 			Assert.Throws<InvalidCastException>(() => reader.GetFieldValue<Stream>(0));
 		}
 
+		[Fact]
+		public virtual async Task GetFieldValueAsync_for_Stream_throws_for_null_Binary()
+		{
+			using var connection = CreateOpenConnection();
+			using var command = connection.CreateCommand();
+			command.CommandText = Fixture.CreateSelectSql(DbType.Binary, ValueKind.Null);
+			using var reader = await command.ExecuteReaderAsync();
+			await reader.ReadAsync();
+			await Assert.ThrowsAsync<InvalidCastException>(async () => await reader.GetFieldValueAsync<Stream>(0));
+		}
+
 		[Fact]
 		public virtual void FieldCount_is_zero_after_Delete() => Test_X_after_Delete(x => Assert.Equal(0, x.FieldCount));