14 instantiations of MessageBuffer
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
598_messageBuffer = new MessageBuffer(_connectionContext, Protocol, _statefulReconnectBufferSize, _logger, _timeProvider);
Microsoft.AspNetCore.SignalR.Tests (13)
Internal\MessageBufferTests.cs (13)
25using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1, NullLogger.Instance); 53using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 91using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 131using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 181using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 236using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 280using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 304using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 347using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1, NullLogger.Instance); 384using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 427using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance, timeProvider); 464using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 507using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance, timeProvider);
18 references to MessageBuffer
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
40private MessageBuffer? _messageBuffer;
Microsoft.AspNetCore.SignalR.Tests (17)
Internal\MessageBufferTests.cs (17)
25using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1, NullLogger.Instance); 53using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 91using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 131using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 181using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 236using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 280using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1000, NullLogger.Instance); 304using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 347using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 1, NullLogger.Instance); 384using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 427using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance, timeProvider); 433timeProvider.Advance(MessageBuffer.AckRate); 445timeProvider.Advance(MessageBuffer.AckRate); 464using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance); 507using var messageBuffer = new MessageBuffer(connection, protocol, bufferLimit: 100_000, NullLogger.Instance, timeProvider); 524timeProvider.Advance(MessageBuffer.AckRate); 532timeProvider.Advance(MessageBuffer.AckRate);