21 references to ShouldProcessMessage
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
806return _messageBuffer.ShouldProcessMessage(message);
Microsoft.AspNetCore.SignalR.Tests (20)
Internal\MessageBufferTests.cs (20)
146Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 147Assert.True(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 148Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 167messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 169Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 170Assert.False(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 200Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 201Assert.True(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 202Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 223messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 225Assert.True(messageBuffer.ShouldProcessMessage(PingMessage.Instance)); 226Assert.False(messageBuffer.ShouldProcessMessage(CompletionMessage.WithResult("1", null))); 294Assert.Throws<InvalidOperationException>(() => messageBuffer.ShouldProcessMessage(new SequenceMessage(2))); 430Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 431Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 443Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 475Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 517Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 518Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null))); 519Assert.True(messageBuffer.ShouldProcessMessage(new StreamItemMessage("1", null)));