1 write to _application
Microsoft.AspNetCore.Http.Connections.Client (1)
Internal\ServerSentEventsTransport.cs (1)
78_application = pair.Application;
9 references to _application
Microsoft.AspNetCore.Http.Connections.Client (9)
Internal\ServerSentEventsTransport.cs (9)
90Debug.Assert(_application != null); 94var sending = SendUtils.SendMessages(url, _application, _httpClient, _logger, _inputCts.Token); 108_application.Input.CancelPendingRead(); 120_application.Output.CancelPendingFlush(); 128Debug.Assert(_application != null); 146var flushResult = await _application.Output.WriteAsync(item.Data, default).ConfigureAwait(false); 167_application.Output.Complete(_error); 178if (_application == null) 187_application.Input.CancelPendingRead();