File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -17,7 +17,7 @@ public class DefaultEventQueue : IEventQueue {
17
17
private readonly IJsonSerializer _serializer ;
18
18
private Timer _queueTimer ;
19
19
private Task _processingQueueTask ;
20
- private readonly object sync = new object ( ) ;
20
+ private readonly object _sync = new object ( ) ;
21
21
private readonly TimeSpan _processQueueInterval = TimeSpan . FromSeconds ( 10 ) ;
22
22
private DateTime ? _suspendProcessingUntil ;
23
23
private DateTime ? _discardQueuedItemsUntil ;
@@ -59,11 +59,10 @@ public Task Process() {
59
59
}
60
60
61
61
TaskCompletionSource < bool > tcs ;
62
- lock ( sync ) {
62
+ lock ( _sync ) {
63
63
if ( _processingQueueTask != null ) {
64
64
return _processingQueueTask ;
65
- }
66
- else {
65
+ } else {
67
66
tcs = new TaskCompletionSource < bool > ( ) ;
68
67
_processingQueueTask = tcs . Task ;
69
68
}
@@ -143,7 +142,7 @@ public Task Process() {
143
142
SuspendProcessing ( ) ;
144
143
} finally {
145
144
tcs . SetResult ( true ) ;
146
- lock ( sync ) {
145
+ lock ( _sync ) {
147
146
_processingQueueTask = null ;
148
147
resultTask = tcs . Task ;
149
148
}
You can’t perform that action at this time.
0 commit comments