Skip to content

Commit 9b8c8e8

Browse files
committed
Rename
1 parent 66acbd5 commit 9b8c8e8

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

projects/RabbitMQ.Client/client/impl/AsyncEventingWrapper.cs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -7,30 +7,30 @@ namespace RabbitMQ.Client.Impl
77
{
88
internal struct AsyncEventingWrapper<TEvent> where TEvent : AsyncEventArgs
99
{
10-
private event AsyncEventHandler<TEvent>? _event;
10+
private event AsyncEventHandler<TEvent>? _eventHandler;
1111
private Delegate[]? _handlers;
1212
private string? _context;
1313
private Func<Exception, string, CancellationToken, Task>? _onException;
1414

15-
public bool IsEmpty => _event is null;
15+
public bool IsEmpty => _eventHandler is null;
1616

1717
public AsyncEventingWrapper(string context, Func<Exception, string, CancellationToken, Task> onException)
1818
{
19-
_event = null;
19+
_eventHandler = null;
2020
_handlers = null;
2121
_context = context;
2222
_onException = onException;
2323
}
2424

2525
public void AddHandler(AsyncEventHandler<TEvent>? handler)
2626
{
27-
_event += handler;
27+
_eventHandler += handler;
2828
_handlers = null;
2929
}
3030

3131
public void RemoveHandler(AsyncEventHandler<TEvent>? handler)
3232
{
33-
_event -= handler;
33+
_eventHandler -= handler;
3434
_handlers = null;
3535
}
3636

@@ -40,7 +40,7 @@ public Task InvokeAsync(object sender, TEvent parameter)
4040
Delegate[]? handlers = _handlers;
4141
if (handlers is null)
4242
{
43-
handlers = _event?.GetInvocationList();
43+
handlers = _eventHandler?.GetInvocationList();
4444
if (handlers is null)
4545
{
4646
return Task.CompletedTask;
@@ -78,7 +78,7 @@ await _onException(exception, _context!, @event.CancellationToken)
7878

7979
public void Takeover(in AsyncEventingWrapper<TEvent> other)
8080
{
81-
_event = other._event;
81+
_eventHandler = other._eventHandler;
8282
_handlers = other._handlers;
8383
_context = other._context;
8484
_onException = other._onException;

0 commit comments

Comments
 (0)