Update AsyncGenerator to 0.8.2.2

Code regenerated to add missing OperationCanceledException where required.

Fixes nhibernate#1674

Author: hazzik

Tools/packages.config

@@ -7,7 +7,7 @@
   <package id="NUnit.Extension.NUnitV2ResultWriter" version="3.6.0" targetFramework="net461" />
   <package id="NUnit.Extension.TeamCityEventListener" version="1.0.2" targetFramework="net461" />
   <package id="NUnit.Extension.VSProjectLoader" version="3.6.0" targetFramework="net461" />
-  <package id="CSharpAsyncGenerator.CommandLine" version="0.8.2.1" targetFramework="net461" />
+  <package id="CSharpAsyncGenerator.CommandLine" version="0.8.2.2" targetFramework="net461" />
   <package id="vswhere" version="2.1.4" targetFramework="net461" />
   <package id="gitreleasemanager" version="0.7.0" targetFramework="net461" />
 </packages>

src/NHibernate.Test/Async/Cascade/Circle/MultiPathCircleCascadeTest.cs

@@ -155,6 +155,7 @@ public async Task MergeEntityWithNonNullableEntityNullAsync()
 					await (session.MergeAsync(route, cancellationToken));
 					Assert.Fail("should have thrown an exception");
 				}
+				catch (OperationCanceledException) { throw; }
 				catch (Exception ex)
 				{
 					Assert.That(ex, Is.TypeOf(typeof(PropertyValueException)));

src/NHibernate.Test/Async/DebugConnectionProvider.cs

@@ -30,6 +30,7 @@ public override async Task<DbConnection> GetConnectionAsync(CancellationToken ca
 				connections.TryAdd(connection, 0);
 				return connection;
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (Exception e)
 			{
 				throw new HibernateException("Could not open connection to: " + ConnectionString, e);

src/NHibernate.Test/Async/NHSpecificTest/NH1553/MsSQL/SnapshotIsolationUpdateConflictTest.cs

@@ -77,16 +77,17 @@ private void SavePerson(Person p)
 		/// Tests, that NHibernate detects the update conflict and returns a StaleObjectStateException as expected.
 		/// This behaviour is part of the standard NHibernate feature set.
 		/// </summary>
+		/// <param name="cancellationToken">A cancellation token that can be used to cancel the work</param>
 		[Test]
-		public async Task UpdateConflictDetectedByNHAsync()
+		public async Task UpdateConflictDetectedByNHAsync(CancellationToken cancellationToken = default(CancellationToken))
 		{
-			Person p1 = await (LoadPersonAsync());
-			Person p2 = await (LoadPersonAsync());
+			Person p1 = await (LoadPersonAsync(cancellationToken));
+			Person p2 = await (LoadPersonAsync(cancellationToken));
 
 			p1.IdentificationNumber++;
 			p2.IdentificationNumber += 2;
 
-			await (SavePersonAsync(p1));
+			await (SavePersonAsync(p1, cancellationToken));
 			Assert.That(p1.Version, Is.EqualTo(person.Version + 1));
 
 			var expectedException = Sfi.Settings.IsBatchVersionedDataEnabled
@@ -95,7 +96,7 @@ public async Task UpdateConflictDetectedByNHAsync()
 				        .And.Property("EntityName").EqualTo(typeof(Person).FullName)
 				        .And.Property("Identifier").EqualTo(p2.Id);
 
-			Assert.That(() => SavePersonAsync(p2), expectedException);
+			Assert.That(() => SavePersonAsync(p2, cancellationToken), expectedException);
 		}
 
 		/// <summary>

src/NHibernate/Async/AdoNet/AbstractBatcher.cs

@@ -123,6 +123,7 @@ public async Task<int> ExecuteNonQueryAsync(DbCommand cmd, CancellationToken can
 			{
 				return await (cmd.ExecuteNonQueryAsync(cancellationToken)).ConfigureAwait(false);
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (Exception e)
 			{
 				e.Data["actual-sql-query"] = cmd.CommandText;
@@ -150,6 +151,7 @@ public virtual async Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, Cancel
 			{
 				reader = await (cmd.ExecuteReaderAsync(cancellationToken)).ConfigureAwait(false);
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (Exception e)
 			{
 				e.Data["actual-sql-query"] = cmd.CommandText;

src/NHibernate/Async/Collection/Generic/PersistentGenericIdentifierBag.cs

@@ -193,6 +193,7 @@ public override async Task PreInsertAsync(ICollectionPersister persister, Cancel
 					}
 				}
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (Exception sqle)
 			{
 				throw new ADOException("Could not generate idbag row id.", sqle);

src/NHibernate/Async/Connection/DriverConnectionProvider.cs

@@ -39,6 +39,7 @@ public override async Task<DbConnection> GetConnectionAsync(CancellationToken ca
 				conn.ConnectionString = ConnectionString;
 				await (conn.OpenAsync(cancellationToken)).ConfigureAwait(false);
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (Exception)
 			{
 				conn.Dispose();

src/NHibernate/Async/Context/ThreadLocalSessionContext.cs

@@ -38,13 +38,15 @@ private static async Task CleanupAnyOrphanedSessionAsync(ISessionFactory factory
 						{
 							await (orphan.Transaction.RollbackAsync(cancellationToken)).ConfigureAwait(false);
 						}
+						catch (OperationCanceledException) { throw; }
 						catch (Exception ex)
 						{
 							log.Debug(ex, "Unable to rollback transaction for orphaned session");
 						}
 					}
 					orphan.Close();
 				}
+				catch (OperationCanceledException) { throw; }
 				catch (Exception ex)
 				{
 					log.Debug(ex, "Unable to close orphaned session");

src/NHibernate/Async/Dialect/Lock/SelectLockingStrategy.cs

@@ -64,6 +64,7 @@ public async Task LockAsync(object id, object version, object obj, ISessionImple
 					session.Batcher.CloseCommand(st, rs);
 				}
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (HibernateException)
 			{
 				// Do not call Convert on HibernateExceptions

src/NHibernate/Async/Driver/NDataReader.cs

@@ -60,6 +60,7 @@ public static async Task<NDataReader> CreateAsync(DbDataReader reader, bool isMi
 
 				dataReader.results = resultList.ToArray();
 			}
+			catch (OperationCanceledException) { throw; }
 			catch (Exception e)
 			{
 				throw new ADOException("There was a problem converting an DbDataReader to NDataReader", e);