9 instantiations of NativeRpcFraming
Aspire.Hosting.Native.Core.Tests (8)
NativeFramingTests.cs (7)
25
var framing = new
NativeRpcFraming
(stream);
40
var framing = new
NativeRpcFraming
(stream);
55
await Assert.ThrowsAsync<InvalidDataException>(() => new
NativeRpcFraming
(stream).ReadAsync(TestContext.Current.CancellationToken));
100
var reader = new
NativeRpcFraming
(stream);
113
var reader = new
NativeRpcFraming
(stream);
131
var reader = new
NativeRpcFraming
(stream);
141
var reader = new
NativeRpcFraming
(stream);
TestServices\NativeSocketTestHost.cs (1)
89
_framing = new
NativeRpcFraming
(_stream, 4 * 1024 * 1024);
Aspire.Hosting.Native.Server (1)
Rpc\NativeRpcPeer.cs (1)
80
var framing = new
NativeRpcFraming
(stream, options.MaximumRequestBytes);
15 references to NativeRpcFraming
Aspire.Hosting.Native.Core.Tests (13)
NativeCliProtocolTests.cs (1)
139
await
NativeRpcFraming
.WriteAsync(stream, notification, TestContext.Current.CancellationToken);
NativeFramingTests.cs (10)
25
var
framing = new NativeRpcFraming(stream);
40
var
framing = new NativeRpcFraming(stream);
62
await
NativeRpcFraming
.WriteAsync(stream,
64
await
NativeRpcFraming
.WriteAsync(stream,
100
var
reader = new NativeRpcFraming(stream);
110
await
NativeRpcFraming
.WriteAsync(stream, Encoding.UTF8.GetBytes("{\"message\":\"caf\u00e9\"}"), CancellationToken.None);
111
await
NativeRpcFraming
.WriteAsync(stream, "{}"u8.ToArray(), CancellationToken.None);
113
var
reader = new NativeRpcFraming(stream);
131
var
reader = new NativeRpcFraming(stream);
141
var
reader = new NativeRpcFraming(stream);
TestServices\NativeSocketTestHost.cs (2)
60
private readonly
NativeRpcFraming
_framing;
110
return
NativeRpcFraming
.WriteAsync(_stream, Encoding.UTF8.GetBytes(request.ToJsonString()), cancellationToken);
Aspire.Hosting.Native.Server (2)
Rpc\NativeRpcPeer.cs (2)
80
var
framing = new NativeRpcFraming(stream, options.MaximumRequestBytes);
192
await
NativeRpcFraming
.WriteAsync(stream, payload, cancellationToken).ConfigureAwait(false);