Some more async variants of existing .Store() tests

Author: alex-kulakov

Orm/Xtensive.Orm.Tests/Linq/LocalCollectionsTest.cs

@@ -14,6 +14,7 @@
 using Xtensive.Orm.Tests.Linq.LocalCollectionsTest_Model;
 using Xtensive.Orm.Tests.ObjectModel;
 using Xtensive.Orm.Tests.ObjectModel.ChinookDO;
+using System.Threading.Tasks;
 
 namespace Xtensive.Orm.Tests.Linq.LocalCollectionsTest_Model
 {
@@ -253,7 +254,7 @@ public void Pair2Test()
     [Test]
     public void Poco1Test()
     {
-      Assert.Throws<QueryTranslationException>(() => {
+      _ = Assert.Throws<QueryTranslationException>(() => {
         var pocos = Customers
           .Select(customer => new Poco<string>() { Value = customer.LastName })
           .ToList();
@@ -357,7 +358,7 @@ public void TypeLoop1Test()
       var nodes = new Node[10];
       var query = Session.Query.All<Invoice>()
         .Join(nodes, invoice => invoice.Customer.Address.City, node => node.Name, (invoice, node) => new {invoice, node});
-      Assert.Throws<QueryTranslationException>(() => QueryDumper.Dump(query));
+      _ = Assert.Throws<QueryTranslationException>(() => QueryDumper.Dump(query));
     }
 
     [Test]
@@ -403,7 +404,7 @@ public void AllTest()
     [Test]
     public void KeyTest()
     {
-      Assert.Throws<QueryTranslationException>( () => {
+      _ = Assert.Throws<QueryTranslationException>(() => {
         var keys = Session.Query.All<Invoice>().Take(10).Select(invoice => invoice.Key).ToList();
         var query = Session.Query.All<Invoice>()
           .Join(keys, invoice => invoice.Key, key => key, (invoice, key) => new {invoice, key});
@@ -863,7 +864,6 @@ public void Aggregate1Test()
       Assert.AreEqual(result, expected);
     }
 
-
     [Test]
     public void Aggregate2Test()
     {
@@ -881,10 +881,27 @@ public void Aggregate2Test()
       QueryDumper.Dump(result);
     }
 
+    [Test]
+    public async Task Aggregate2AsyncTest()
+    {
+      Require.AllFeaturesSupported(ProviderFeatures.TemporaryTables);
+      Require.ProviderIsNot(StorageProvider.SqlServerCe);
+      var localItems = GetLocalItems(100);
+      var queryable = Session.Query.Store(localItems);
+      var result = (await Session.Query.All<Invoice>()
+        .Where(invoice => invoice.Commission > queryable.Max(poco => poco.Value2)).AsAsync()).ToList();
+      var expected = Invoices
+        .Where(invoice => invoice.Commission > localItems.Max(poco => poco.Value2));
+
+      Assert.That(result, Is.Not.Empty);
+      Assert.AreEqual(0, expected.Except(result).Count());
+      QueryDumper.Dump(result);
+    }
+
     [Test]
     public void ClosureCacheTest()
     {
-      Assert.Throws<QueryTranslationException>( () => {
+      _ = Assert.Throws<QueryTranslationException>( () => {
         var localItems = GetLocalItems(100);
         var queryable = Session.Query.Store(localItems);
         var result = Session.Query.Execute(qe => qe.All<Invoice>().Where(invoice => invoice.Commission > queryable.Max(poco => poco.Value2)));

Orm/Xtensive.Orm.Tests/Linq/QueryMethodTests.cs

@@ -121,7 +121,7 @@ public void Store1Test()
     }
 
     [Test]
-    public async Task Store1TestAsync()
+    public async Task Store1AsyncTest()
     {
       Require.AllFeaturesSupported(ProviderFeatures.TemporaryTables);
 
@@ -165,6 +165,28 @@ public void Store2Test()
       Assert.AreEqual(0, expected.Except(query).Count());
     }
 
+    [Test]
+    public async Task Store2AsyncTest()
+    {
+      Require.AllFeaturesSupported(ProviderFeatures.TemporaryTables);
+
+      var query = (await Session.Query.All<Customer>()
+        .Join(
+          Session.Query.Store(Session.Query.All<Customer>().Take(10)),
+          customer => customer,
+          localCustomer => localCustomer,
+          (customer, localCustomer) => new { customer, localCustomer }).AsAsync()).ToList();
+      var expected = Session.Query.All<Customer>().AsEnumerable()
+        .Join(
+          Session.Query.Store(Session.Query.All<Customer>().Take(10)),
+          customer => customer,
+          localCustomer => localCustomer,
+          (customer, localCustomer) => new { customer, localCustomer });
+
+      Assert.That(query, Is.Not.Empty);
+      Assert.AreEqual(0, expected.Except(query).Count());
+    }
+
     private IEnumerable<Customer> GetExpectedCustomerAsSequence()
     {
       if (StorageProviderInfo.Instance.CheckProviderIs(StorageProvider.Firebird)) {