25var invocationId = await client.SendHubMessageAsync(new InvocationMessage("1", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 31await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage.InvocationId, res)).DefaultTimeout(); 58var invocationId = await client.SendHubMessageAsync(new InvocationMessage("1", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 63await client.SendHubMessageAsync(CompletionMessage.WithError(invocationMessage.InvocationId, "Client error")).DefaultTimeout(); 155await client.SendHubMessageAsync(CompletionMessage.WithResult(invocation.InvocationId, 2)).DefaultTimeout(); 189await client.SendHubMessageAsync(CompletionMessage.WithResult(invocation.InvocationId, 2)).DefaultTimeout(); 208var invocationId = await client.SendHubMessageAsync(new InvocationMessage( 220await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage.InvocationId, res)).DefaultTimeout(); 244_ = await client.SendHubMessageAsync(new InvocationMessage("1", nameof(MethodHub.BlockingMethod), Array.Empty<object>())).DefaultTimeout(); 247var invocationId = await client.SendHubMessageAsync(new InvocationMessage("2", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 248var invocationId2 = await client.SendHubMessageAsync(new InvocationMessage("3", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 249var invocationId3 = await client.SendHubMessageAsync(new InvocationMessage("4", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 261await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage.InvocationId, res)).DefaultTimeout(); 267await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage2.InvocationId, res)).DefaultTimeout(); 273await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage3.InvocationId, res)).DefaultTimeout(); 310await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage.InvocationId, res)).DefaultTimeout(); 388await client.SendHubMessageAsync(CompletionMessage.WithResult(invocation.InvocationId, 2)).DefaultTimeout(); 433await client.SendHubMessageAsync(CompletionMessage.WithResult(invocation.InvocationId, 2)).DefaultTimeout(); 468await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage.InvocationId, res)).DefaultTimeout(); 503await client.SendHubMessageAsync(CompletionMessage.WithResult(invocationMessage.InvocationId, res)).DefaultTimeout();

2054await client.SendHubMessageAsync(new StreamInvocationMessage(invocationId, nameof(StreamingHub.BlockingStream), Array.Empty<object>())); 2057await client.SendHubMessageAsync(new CancelInvocationMessage(invocationId)).DefaultTimeout(); 2677await client.SendHubMessageAsync(PingMessage.Instance).DefaultTimeout(); 2849await client.SendHubMessageAsync(PingMessage.Instance); 2882await client.SendHubMessageAsync(PingMessage.Instance); 2912await client.SendHubMessageAsync(PingMessage.Instance); 2918await client.SendHubMessageAsync(PingMessage.Instance); 3028await client.SendHubMessageAsync(PingMessage.Instance); 3084await client.SendHubMessageAsync(PingMessage.Instance); 3190await client.SendHubMessageAsync(new StreamInvocationMessage("1", nameof(StreamingHub.BlockingStream), Array.Empty<object>())).DefaultTimeout(); 3296await client.SendHubMessageAsync(new StreamInvocationMessage("123", nameof(StreamingHub.BlockingStream), Array.Empty<object>())).DefaultTimeout(); 3298await client.SendHubMessageAsync(new StreamInvocationMessage("123", nameof(StreamingHub.BlockingStream), Array.Empty<object>())).DefaultTimeout(); 3534await client.SendHubMessageAsync(new CancelInvocationMessage(streamInvocationId)).DefaultTimeout(); 3606await client.SendHubMessageAsync(new StreamItemMessage("id", letter)).DefaultTimeout(); 3630await client.SendHubMessageAsync(new StreamItemMessage("id", letter)).DefaultTimeout(); 3633await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 3654await client.SendHubMessageAsync(new StreamItemMessage("id", thing)).DefaultTimeout(); 3657await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 3690await client.SendHubMessageAsync(new StreamItemMessage(spot.ToString(CultureInfo.InvariantCulture), words[spot][pos[spot]])).DefaultTimeout(); 3696await client.SendHubMessageAsync(CompletionMessage.Empty(id)).DefaultTimeout(); 3747await client.SendHubMessageAsync(new StreamItemMessage("id", thing)).DefaultTimeout(); 3752await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 3784await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 3876await client.SendHubMessageAsync(new StreamItemMessage("id", 5)).DefaultTimeout(); 3877await client.SendHubMessageAsync(new StreamItemMessage("id", 10)).DefaultTimeout(); 3879await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 3928await client.SendHubMessageAsync(new StreamItemMessage("channelId", "not a number")).DefaultTimeout(); 3951await client.SendHubMessageAsync(new StreamItemMessage("fake_id", "not a number")).DefaultTimeout(); 3976await client.SendHubMessageAsync(CompletionMessage.Empty("fake_id")).DefaultTimeout(); 4001await client.SendHubMessageAsync(CompletionMessage.WithError("id", CustomErrorMessage)).DefaultTimeout(); 4064await client.SendHubMessageAsync(new StreamItemMessage("id", "hello")).DefaultTimeout(); 4065await client.SendHubMessageAsync(new StreamItemMessage("id", " world")).DefaultTimeout(); 4066await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 4105await client.SendHubMessageAsync(new StreamItemMessage("id", "hello")).DefaultTimeout(); 4106await client.SendHubMessageAsync(new StreamItemMessage("id", " world")).DefaultTimeout(); 4110await client.SendHubMessageAsync(CompletionMessage.Empty("id")).DefaultTimeout(); 4139await client.SendHubMessageAsync(new StreamItemMessage("id", "ignored")).DefaultTimeout(); 4146await client.SendHubMessageAsync(new StreamItemMessage("id", "error!")).DefaultTimeout(); 4176await client.SendHubMessageAsync(new StreamItemMessage("id", "ignored")).DefaultTimeout(); 4183await client.SendHubMessageAsync(new StreamItemMessage("id", "error!")).DefaultTimeout(); 4225await client.SendHubMessageAsync(new CancelInvocationMessage(streamInvocationId)).DefaultTimeout(); 4273await client.SendHubMessageAsync(new CancelInvocationMessage(invocationId)).DefaultTimeout(); 4370await client.SendHubMessageAsync(new CancelInvocationMessage(streamInvocationId)).DefaultTimeout(); 4426await client.SendHubMessageAsync(new StreamItemMessage(streamId, phrase)); 4428await client.SendHubMessageAsync(CompletionMessage.Empty(streamId)); 4576await client.SendHubMessageAsync(new StreamItemMessage("id", "hello")).DefaultTimeout(); 4718await client.SendHubMessageAsync(new StreamItemMessage("1", 1)).DefaultTimeout(); 4719await client.SendHubMessageAsync(new StreamItemMessage("1", 14)).DefaultTimeout(); 4721await client.SendHubMessageAsync(CompletionMessage.Empty("1")).DefaultTimeout(); 5123await client.SendHubMessageAsync(new CloseMessage(error: null)); 5148await client.SendHubMessageAsync(new CloseMessage(error: errorMessage)); 5179await client.SendHubMessageAsync(new SequenceMessage(10)).DefaultTimeout(); 5180await client.SendHubMessageAsync(new AckMessage(234)).DefaultTimeout(); 5218await client.SendHubMessageAsync(new AckMessage(1)).DefaultTimeout(); 5261await client.SendHubMessageAsync(new SequenceMessage(1)).DefaultTimeout(); 5263await client.SendHubMessageAsync(new CloseMessage(error: null)); 5319await client.SendHubMessageAsync(new CloseMessage(error: null));

207return SendHubMessageAsync(new InvocationMessage(invocationId, methodName, args) { Headers = headers }); 223return SendHubMessageAsync(new StreamInvocationMessage(invocationId, methodName, args, streamIds) { Headers = headers }); 229return SendHubMessageAsync(message);