Skip to content
This repository was archived by the owner on Dec 18, 2018. It is now read-only.

Commit e344e7a

Browse files
committed
pr feedback
1 parent 0b3f4df commit e344e7a

File tree

3 files changed

+2
-8
lines changed

3 files changed

+2
-8
lines changed

src/Microsoft.AspNetCore.SignalR.Core/Properties/AssemblyInfo.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,5 +3,4 @@
33

44
using System.Runtime.CompilerServices;
55

6-
//[assembly: InternalsVisibleTo("Microsoft.AspNetCore.SignalR.Tests, PublicKey=0024000004800000940000000602000000240000525341310004000001000100f33a29044fa9d740c9b3213a93e57c84b472c84e0b8a0e1ae48e67a9f8f6de9d5f7f3d52ac23e48ac51801f1dc950abe901da34d2a9e3baadb141a17c77ef3c565dd5ee5054b91cf63bb3c6ab83f72ab3aafe93d0fc3c2348b764fafb0b1c0733de51459aeab46580384bf9d74c4e28164b7cde247f891ba07891c9d872ad2bb")]
76
[assembly: InternalsVisibleTo("Microsoft.AspNetCore.SignalR.Tests.Utils, PublicKey=0024000004800000940000000602000000240000525341310004000001000100f33a29044fa9d740c9b3213a93e57c84b472c84e0b8a0e1ae48e67a9f8f6de9d5f7f3d52ac23e48ac51801f1dc950abe901da34d2a9e3baadb141a17c77ef3c565dd5ee5054b91cf63bb3c6ab83f72ab3aafe93d0fc3c2348b764fafb0b1c0733de51459aeab46580384bf9d74c4e28164b7cde247f891ba07891c9d872ad2bb")]

src/Microsoft.AspNetCore.Sockets.Http/HttpConnectionDispatcher.cs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -143,9 +143,6 @@ private async Task ExecuteEndpointAsync(HttpContext context, SocketDelegate sock
143143
{
144144
// GET /{path} maps to long polling
145145

146-
// Initialze Long Polling connection features
147-
148-
149146
// Connection must already exist
150147
var connection = await GetConnectionAsync(context);
151148
if (connection == null)
@@ -217,7 +214,7 @@ private async Task ExecuteEndpointAsync(HttpContext context, SocketDelegate sock
217214
context.Response.RegisterForDispose(timeoutSource);
218215
context.Response.RegisterForDispose(tokenSource);
219216

220-
var longPolling = new LongPollingTransport(timeoutSource.Token, options.LongPolling.PollTimeout, connection.Application.Reader, connection.ConnectionId, _loggerFactory);
217+
var longPolling = new LongPollingTransport(timeoutSource.Token, connection.Application.Reader, connection.ConnectionId, _loggerFactory);
221218

222219
// Start the transport
223220
connection.TransportTask = longPolling.ProcessRequestAsync(context, tokenSource.Token);

src/Microsoft.AspNetCore.Sockets.Http/Internal/Transports/LongPollingTransport.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,11 @@ public class LongPollingTransport : IHttpTransport
1717
private readonly ChannelReader<byte[]> _application;
1818
private readonly ILogger _logger;
1919
private readonly CancellationToken _timeoutToken;
20-
private readonly TimeSpan _timeout;
2120
private readonly string _connectionId;
2221

23-
public LongPollingTransport(CancellationToken timeoutToken, TimeSpan timeout, ChannelReader<byte[]> application, string connectionId, ILoggerFactory loggerFactory)
22+
public LongPollingTransport(CancellationToken timeoutToken, ChannelReader<byte[]> application, string connectionId, ILoggerFactory loggerFactory)
2423
{
2524
_timeoutToken = timeoutToken;
26-
_timeout = timeout;
2725
_application = application;
2826
_connectionId = connectionId;
2927
_logger = loggerFactory.CreateLogger<LongPollingTransport>();

0 commit comments

Comments
 (0)