1 write to _providers
Aspire.Hosting.Native.Server (1)
Rpc\NativeRpcConnection.cs (1)
45_providers = providers;
19 references to _providers
Aspire.Hosting.Native.Server (19)
Rpc\NativeRpcConnection.cs (1)
499_providers?.Disconnect(this);
Rpc\NativeRpcConnection.Dispatch.cs (18)
54_providers?.IsProvider(this) == true) 87if (_providers is not null) 89if (_providers.IsProvider(this)) 91return await _providers.InvokeCoreAsync(this, capabilityId, capabilityArguments).ConfigureAwait(false); 95return await _providers.InvokeAsync(this, capabilityId, capabilityArguments).ConfigureAwait(false); 107if (_providers is null || parameters is not null and not JsonArray { Count: 0 }) 111return _providers.InspectCapabilities(); 113if (_providers is null || parameters is not JsonArray { Count: 1 } expectation || _providers.IsProvider(this)) 117return JsonValue.Create(_providers.Expect(this, RpcArguments.String(expectation[0]))); 119if (_providers is null || _peer is null || parameters is not JsonArray { Count: 1 } registration) 123await _providers.RegisterAsync(this, RpcArguments.String(registration[0]), _peer).ConfigureAwait(false); 126if (_providers is null || parameters is not JsonArray { Count: 1 } activation) 130await _providers.WaitRegistrationAsync(this, RpcArguments.String(activation[0])).ConfigureAwait(false); 133if (_providers is null || parameters is not JsonArray { Count: 1 } abandonment) 137return JsonValue.Create(_providers.AbandonRegistration(this, RpcArguments.String(abandonment[0]))); 139if (_providers is null || parameters is not JsonArray { Count: 2 } callback || callback[1] is not JsonObject callbackArguments) 143return await _providers.InvokeCallbackAsync(this, RpcArguments.String(callback[0]), callbackArguments).ConfigureAwait(false);