21 references to ShouldProcessMessage
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
848return _messageBuffer.ShouldProcessMessage(message);
Microsoft.AspNetCore.SignalR.Tests (20)
Internal\MessageBufferTests.cs (20)
150Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 151Assert.True(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 152Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 171messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 173Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 174Assert.False(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 205Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 206Assert.True(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 207Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 228messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 230Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 231Assert.False(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 300Assert.Throws<InvalidOperationException>(() => messageBuffer.ShouldProcessMessage(new SequenceMessage(2))); 439Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 440Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 452Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 485Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 528Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 529Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 530Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null)));