Base:
property
Transport
Microsoft.AspNetCore.Connections.ConnectionContext.Transport
28 references to Transport
ClientSample (2)
RawSample.cs (2)
57_ = ReceiveLoop(Console.Out, connection.Transport.Input); 58_ = SendLoop(Console.In, connection.Transport.Output);
Microsoft.AspNetCore.Http.Connections.Client (1)
HttpConnection.cs (1)
63throw new InvalidOperationException($"Cannot access the {nameof(Transport)} pipe before the connection has started.");
Microsoft.AspNetCore.Http.Connections.Tests (2)
HttpConnectionDispatcherTests.cs (2)
3554await connection.Transport.Output.WriteAsync(new byte[2]); 3555await connection.Transport.Input.ReadAsync();
Microsoft.AspNetCore.SignalR.Client.Tests (17)
HttpConnectionTests.ConnectionLifecycle.cs (2)
315await connection.Transport.Output.WriteAsync(new byte[] { 0x42 }).DefaultTimeout(); 317await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAsync());
HttpConnectionTests.Transport.cs (15)
70await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 71await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 2")); 146await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 186await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 218Assert.Contains("This is a test", Encoding.UTF8.GetString(await connection.Transport.Input.ReadAllAsync())); 246await connection.Transport.Output.WriteAsync(data).DefaultTimeout(); 262() => connection.Transport.Output.WriteAsync(new byte[0]).DefaultTimeout()); 278() => connection.Transport.Output.WriteAsync(new byte[0]).DefaultTimeout()); 409var message = await connection.Transport.Input.ReadAtLeastAsync(14); 412await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 447await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAllAsync()); 507await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 510await connection.Transport.Input.ReadAllAsync(); 550await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 551await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAllAsync());
Microsoft.AspNetCore.SignalR.Tests (6)
EndToEndTests.cs (6)
193await connection.Transport.Output.WriteAsync(message).DefaultTimeout(); 195var receivedData = await connection.Transport.Input.ReadAsync(1); 279await connection.Transport.Output.WriteAsync(bytes).DefaultTimeout(); 293Assert.Equal(message, Encoding.UTF8.GetString(await connection.Transport.Input.ReadAsync(bytes.Length).DefaultTimeout())); 336await connection.Transport.Output.WriteAsync(bytes).DefaultTimeout(); 344var receivedData = await connection.Transport.Input.ReadAsync(bytes.Length).DefaultTimeout();