1 implementation of INativeRpcPeer
Aspire.Hosting.Native.Server (1)
Rpc\NativeRpcPeer.cs (1)
19
internal sealed class NativeRpcPeer(Stream stream, NativeServerOptions options, ILogger logger) :
INativeRpcPeer
15 references to INativeRpcPeer
Aspire.Hosting.Native.Server (15)
Rpc\INativeRpcPeer.cs (1)
21
INativeRpcPeer
Create(Stream stream);
Rpc\NativeBackchannelRpc.cs (1)
27
using
var
peer = peers.Create(stream);
Rpc\NativeProviderLifecycle.cs (2)
65
var
peer = registration.Peer;
123
INativeRpcPeer
? peer;
Rpc\NativeProviderRegistry.cs (7)
17
Task RegisterAsync(NativeRpcConnection connection, string authority,
INativeRpcPeer
peer);
66
public async Task RegisterAsync(NativeRpcConnection connection, string authority,
INativeRpcPeer
peer)
455
var peers = new List<
INativeRpcPeer
>();
486
foreach (
var
peer in peers)
492
internal sealed class Registration(NativeRpcConnection owner, NativeRpcConnection connection,
INativeRpcPeer
peer,
497
private
INativeRpcPeer
? _peer = peer;
500
public
INativeRpcPeer
Peer => _peer ?? throw Unavailable();
Rpc\NativeRpcConnection.cs (2)
36
private
INativeRpcPeer
? _peer;
43
internal void AttachProviderTransport(INativeProviderRegistry providers,
INativeRpcPeer
peer)
Rpc\NativeRpcListener.cs (1)
192
using
var
peer = _peers.Create(stream);
Rpc\NativeRpcPeer.cs (1)
15
public
INativeRpcPeer
Create(Stream stream) => new NativeRpcPeer(stream, options, logger);