@@ -60,7 +60,7 @@ public class TestAsyncConsumer
60
60
{
61
61
62
62
[ Test ]
63
- public async Task TestBasicRoundtrip ( )
63
+ public void TestBasicRoundtrip ( )
64
64
{
65
65
var cf = new ConnectionFactory { DispatchConsumersAsync = true } ;
66
66
using ( var c = cf . CreateConnection ( ) )
@@ -71,20 +71,20 @@ public async Task TestBasicRoundtrip()
71
71
var body = System . Text . Encoding . UTF8 . GetBytes ( "async-hi" ) ;
72
72
m . BasicPublish ( "" , q . QueueName , bp , body ) ;
73
73
var consumer = new AsyncEventingBasicConsumer ( m ) ;
74
- var sem = new SemaphoreSlim ( 0 ) ;
74
+ var are = new AutoResetEvent ( false ) ;
75
75
consumer . Received += async ( o , a ) =>
76
76
{
77
- sem . Release ( ) ;
78
- await Task . FromResult ( 0 ) ;
77
+ are . Set ( ) ;
78
+ await Task . Yield ( ) ;
79
79
} ;
80
80
var tag = m . BasicConsume ( q . QueueName , true , consumer ) ;
81
81
// ensure we get a delivery
82
- var waitRes = await sem . WaitAsync ( 2000 ) ;
82
+ var waitRes = are . WaitOne ( 2000 ) ;
83
83
Assert . IsTrue ( waitRes ) ;
84
84
// unsubscribe and ensure no further deliveries
85
85
m . BasicCancel ( tag ) ;
86
86
m . BasicPublish ( "" , q . QueueName , bp , body ) ;
87
- var waitResFalse = await sem . WaitAsync ( 100 ) ;
87
+ var waitResFalse = are . WaitOne ( 2000 ) ;
88
88
Assert . IsFalse ( waitResFalse ) ;
89
89
}
90
90
}
0 commit comments