@@ -109,7 +109,6 @@ public IAsyncEnumerable<IOperationResult> ExecuteAsync()
109
109
_requestContext ,
110
110
_sourceStream ,
111
111
OnEvent ,
112
- this ,
113
112
_diagnosticEvents ,
114
113
_errorHandler ) ;
115
114
@@ -322,22 +321,19 @@ private sealed class SubscriptionEnumerable : IAsyncEnumerable<IOperationResult>
322
321
private readonly RequestContext _requestContext ;
323
322
private readonly ISourceStream _sourceStream ;
324
323
private readonly Func < object , Task < IOperationResult > > _onEvent ;
325
- private readonly Subscription _subscription ;
326
324
private readonly IExecutionDiagnosticEvents _diagnosticEvents ;
327
325
private readonly IErrorHandler _errorHandler ;
328
326
329
327
public SubscriptionEnumerable (
330
328
RequestContext requestContext ,
331
329
ISourceStream sourceStream ,
332
330
Func < object , Task < IOperationResult > > onEvent ,
333
- Subscription subscription ,
334
331
IExecutionDiagnosticEvents diagnosticEvents ,
335
332
IErrorHandler errorHandler )
336
333
{
337
334
_requestContext = requestContext ;
338
335
_sourceStream = sourceStream ;
339
336
_onEvent = onEvent ;
340
- _subscription = subscription ;
341
337
_diagnosticEvents = diagnosticEvents ;
342
338
_errorHandler = errorHandler ;
343
339
}
@@ -355,7 +351,6 @@ public IAsyncEnumerator<IOperationResult> GetAsyncEnumerator(
355
351
_requestContext ,
356
352
eventStreamEnumerator ,
357
353
_onEvent ,
358
- _subscription ,
359
354
_diagnosticEvents ,
360
355
_errorHandler ,
361
356
cancellationToken ) ;
@@ -374,7 +369,6 @@ private sealed class SubscriptionEnumerator : IAsyncEnumerator<IOperationResult>
374
369
private readonly RequestContext _requestContext ;
375
370
private readonly IAsyncEnumerator < object ? > _eventEnumerator ;
376
371
private readonly Func < object , Task < IOperationResult > > _onEvent ;
377
- private readonly Subscription _subscription ;
378
372
private readonly IExecutionDiagnosticEvents _diagnosticEvents ;
379
373
private readonly IErrorHandler _errorHandler ;
380
374
private readonly CancellationToken _requestAborted ;
@@ -385,15 +379,13 @@ public SubscriptionEnumerator(
385
379
RequestContext requestContext ,
386
380
IAsyncEnumerator < object ? > eventEnumerator ,
387
381
Func < object , Task < IOperationResult > > onEvent ,
388
- Subscription subscription ,
389
382
IExecutionDiagnosticEvents diagnosticEvents ,
390
383
IErrorHandler errorHandler ,
391
384
CancellationToken requestAborted )
392
385
{
393
386
_requestContext = requestContext ;
394
387
_eventEnumerator = eventEnumerator ;
395
388
_onEvent = onEvent ;
396
- _subscription = subscription ;
397
389
_diagnosticEvents = diagnosticEvents ;
398
390
_errorHandler = errorHandler ;
399
391
_requestAborted = requestAborted ;
0 commit comments