Skip to content

Commit cc6baef

Browse files
maca88fredericDelaporte
maca88
authored and
fredericDelaporte
committed
Upgrade AsyncGenerator to 0.18.2
1 parent cc31c44 commit cc6baef

25 files changed

+315
-315
lines changed

‎Tools/packages.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
</ItemGroup>
1212

1313
<ItemGroup>
14-
<PackageReference Include="CSharpAsyncGenerator.CommandLine" Version="0.18.1" />
14+
<PackageReference Include="CSharpAsyncGenerator.CommandLine" Version="0.18.2" />
1515
<PackageReference Include="vswhere" Version="2.1.4" />
1616
<PackageReference Include="NUnit.Console" Version="3.10.0" />
1717
<PackageReference Include="GitReleaseManager" Version="0.7.0" />

‎src/NHibernate.Test/Async/Futures/FutureCriteriaFixture.cs

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -64,30 +64,30 @@ public async Task CanUseFutureCriteriaAsync()
6464

6565
[Test]
6666
public async Task TwoFuturesRunInTwoRoundTripsAsync()
67-
{
68-
using (var s = Sfi.OpenSession())
69-
{
70-
IgnoreThisTestIfMultipleQueriesArentSupportedByDriver();
71-
72-
using (var logSpy = new SqlLogSpy())
73-
{
74-
var persons10 = s.CreateCriteria(typeof(Person))
67+
{
68+
using (var s = Sfi.OpenSession())
69+
{
70+
IgnoreThisTestIfMultipleQueriesArentSupportedByDriver();
71+
72+
using (var logSpy = new SqlLogSpy())
73+
{
74+
var persons10 = s.CreateCriteria(typeof(Person))
7575
.SetMaxResults(10)
7676
.Future<Person>();
7777

78-
foreach (var person in await (persons10.GetEnumerableAsync())) { } // fire first future round-trip
78+
foreach (var person in await (persons10.GetEnumerableAsync())) { } // fire first future round-trip
7979

80-
var persons5 = s.CreateCriteria(typeof(Person))
80+
var persons5 = s.CreateCriteria(typeof(Person))
8181
.SetMaxResults(5)
8282
.Future<int>();
8383

84-
foreach (var person in await (persons5.GetEnumerableAsync())) { } // fire second future round-trip
84+
foreach (var person in await (persons5.GetEnumerableAsync())) { } // fire second future round-trip
8585

86-
var events = logSpy.Appender.GetEvents();
87-
Assert.AreEqual(2, events.Length);
88-
}
89-
}
90-
}
86+
var events = logSpy.Appender.GetEvents();
87+
Assert.AreEqual(2, events.Length);
88+
}
89+
}
90+
}
9191

9292
[Test]
9393
public async Task CanCombineSingleFutureValueWithEnumerableFuturesAsync()

‎src/NHibernate.Test/Async/Linq/MiscellaneousTextFixture.cs

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -26,14 +26,14 @@ public class MiscellaneousTextFixtureAsync : LinqTestCase
2626
[Category("COUNT/SUM/MIN/MAX/AVG")]
2727
[Test(Description = "This sample uses Count to find the number of Orders placed before yesterday in the database.")]
2828
public async Task CountWithWhereClauseAsync()
29-
{
30-
var yesterday = DateTime.Today.AddDays(-1);
31-
var q = from o in db.Orders where o.OrderDate <= yesterday select o;
29+
{
30+
var yesterday = DateTime.Today.AddDays(-1);
31+
var q = from o in db.Orders where o.OrderDate <= yesterday select o;
3232

33-
var count = await (q.CountAsync());
33+
var count = await (q.CountAsync());
3434

35-
Console.WriteLine(count);
36-
}
35+
Console.WriteLine(count);
36+
}
3737

3838
[Category("From NHUser list")]
3939
[Test(Description = "Telerik grid example, http://www.telerik.com/community/forums/aspnet-mvc/grid/grid-and-nhibernate-linq.aspx")]
@@ -137,17 +137,17 @@ orderby p.ProductId
137137

138138
[Test]
139139
public async Task SelectFromObjectAsync()
140-
{
141-
using (var s = OpenSession())
142-
{
143-
var hql = await (s.CreateQuery("from System.Object o").ListAsync());
140+
{
141+
using (var s = OpenSession())
142+
{
143+
var hql = await (s.CreateQuery("from System.Object o").ListAsync());
144144

145-
var r = from o in s.Query<object>() select o;
145+
var r = from o in s.Query<object>() select o;
146146

147-
var l = await (r.ToListAsync());
147+
var l = await (r.ToListAsync());
148148

149-
Assert.AreEqual(hql.Count, l.Count);
150-
}
151-
}
149+
Assert.AreEqual(hql.Count, l.Count);
150+
}
151+
}
152152
}
153153
}

‎src/NHibernate.Test/Async/Linq/QueryLock.cs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -210,18 +210,18 @@ orderby e.CompanyName
210210
{
211211
// TODO: We should try to verify that the exception actually IS a locking failure and not something unrelated.
212212
Assert.ThrowsAsync<GenericADOException>(
213-
async () =>
213+
async () =>
214214
{
215215
var result2 = await ((
216-
from e in s2.Query<Customer>()
217-
where e.CustomerId == customerId
218-
select e
219-
).WithLock(LockMode.UpgradeNoWait)
220-
.WithOptions(o => o.SetTimeout(5))
221-
.ToListAsync(cancellationToken));
216+
from e in s2.Query<Customer>()
217+
where e.CustomerId == customerId
218+
select e
219+
).WithLock(LockMode.UpgradeNoWait)
220+
.WithOptions(o => o.SetTimeout(5))
221+
.ToListAsync(cancellationToken));
222222
Assert.That(result2, Is.Not.Null);
223223
},
224-
"Expected an exception to indicate locking failure due to already locked.");
224+
"Expected an exception to indicate locking failure due to already locked.");
225225
}
226226
return Task.CompletedTask;
227227
}

‎src/NHibernate.Test/Async/NHSpecificTest/NH2322/PostUpdateEventListener.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,9 @@ Task IPostUpdateEventListener.OnPostUpdateAsync(PostUpdateEvent @event, Cancella
2626
if (@event.Entity is Person)
2727
{
2828
return @event.Session
29-
.CreateSQLQuery("update Person set Name = :newName")
30-
.SetString("newName", "new updated name")
31-
.ExecuteUpdateAsync(cancellationToken);
29+
.CreateSQLQuery("update Person set Name = :newName")
30+
.SetString("newName", "new updated name")
31+
.ExecuteUpdateAsync(cancellationToken);
3232
}
3333
return Task.CompletedTask;
3434
}

‎src/NHibernate.Test/Async/NHSpecificTest/NH2500/Fixture.cs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -62,13 +62,13 @@ protected override void OnTearDown()
6262

6363
[Test]
6464
public async Task TestLinqProjectionExpressionDoesntCacheParametersAsync()
65-
{
66-
using (ISession session = Sfi.OpenSession())
67-
using (ITransaction transaction = session.BeginTransaction())
6865
{
69-
this.count = 1;
66+
using (ISession session = Sfi.OpenSession())
67+
using (ITransaction transaction = session.BeginTransaction())
68+
{
69+
this.count = 1;
7070

71-
var foos1 = await (session.Query<Foo>()
71+
var foos1 = await (session.Query<Foo>()
7272
.Where(x => x.Name == "Banana")
7373
.Select(x => new
7474
{
@@ -77,9 +77,9 @@ public async Task TestLinqProjectionExpressionDoesntCacheParametersAsync()
7777
User = "abc"
7878
}).FirstAsync());
7979

80-
this.count = 2;
80+
this.count = 2;
8181

82-
var foos2 = await (session.Query<Foo>()
82+
var foos2 = await (session.Query<Foo>()
8383
.Where(x => x.Name == "Egg")
8484
.Select(x => new
8585
{
@@ -88,13 +88,13 @@ public async Task TestLinqProjectionExpressionDoesntCacheParametersAsync()
8888
User = "def"
8989
}).FirstAsync());
9090

91-
Assert.AreEqual(1, foos1.count);
92-
Assert.AreEqual(2, foos2.count);
93-
Assert.AreEqual("abc", foos1.User);
94-
Assert.AreEqual("def", foos2.User);
91+
Assert.AreEqual(1, foos1.count);
92+
Assert.AreEqual(2, foos2.count);
93+
Assert.AreEqual("abc", foos1.User);
94+
Assert.AreEqual("def", foos2.User);
9595

96-
await (transaction.CommitAsync());
96+
await (transaction.CommitAsync());
97+
}
9798
}
9899
}
99-
}
100100
}

‎src/NHibernate.Test/Async/NHSpecificTest/NH2898/BinaryFormatterCache.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -32,11 +32,11 @@ public override Task<object> GetAsync(object key, CancellationToken cancellation
3232
return Task.FromResult<object>(null);
3333

3434
var fmt = new BinaryFormatter
35-
{
35+
{
3636
#if !NETFX
37-
SurrogateSelector = new SerializationHelper.SurrogateSelector()
37+
SurrogateSelector = new SerializationHelper.SurrogateSelector()
3838
#endif
39-
};
39+
};
4040
using (var stream = new MemoryStream(entry))
4141
{
4242
return Task.FromResult<object>(fmt.Deserialize(stream));
@@ -53,11 +53,11 @@ public override Task PutAsync(object key, object value, CancellationToken cancel
5353
try
5454
{
5555
var fmt = new BinaryFormatter
56-
{
56+
{
5757
#if !NETFX
58-
SurrogateSelector = new SerializationHelper.SurrogateSelector()
58+
SurrogateSelector = new SerializationHelper.SurrogateSelector()
5959
#endif
60-
};
60+
};
6161
using (var stream = new MemoryStream())
6262
{
6363
fmt.Serialize(stream, value);

0 commit comments

Comments
 (0)