288 references to RpcArguments
Aspire.Hosting.Native.Server (288)
artifacts\obj\Aspire.Hosting.Native.Server\Debug\native-ats\NativeDispatch.g.cs (254)
20RpcArguments.Validate(arguments, ["context", "revision"]); 27RpcArguments.Validate(arguments, ["context", "name", "typeId"]); 30var result = target.AddComputeEnvironment(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["typeId"])); 35RpcArguments.Validate(arguments, ["context", "name", "secret", "publishing"]); 38var result = target.AddConfiguredParameter(RpcArguments.String(arguments["name"]), RpcArguments.Boolean(arguments["secret"]), RpcArguments.Boolean(arguments["publishing"])); 43RpcArguments.Validate(arguments, ["context", "name", "image"]); 46var result = target.AddContainer(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["image"])); 51RpcArguments.Validate(arguments, ["context", "name", "executablePath", "workingDirectory"]); 54var result = target.AddExecutable(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["executablePath"]), RpcArguments.String(arguments["workingDirectory"])); 59RpcArguments.Validate(arguments, ["context", "name", "options", "secret"]); 62var result = target.AddGeneratedParameter(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["options"]), RpcArguments.Boolean(arguments["secret"])); 67RpcArguments.Validate(arguments, ["context", "name"]); 70var result = target.AddGeneratedSecretParameter(RpcArguments.String(arguments["name"])); 75RpcArguments.Validate(arguments, ["context", "name", "value", "secret", "publishValueAsDefault"]); 78var result = target.AddParameterValue(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["value"]), RpcArguments.Boolean(arguments["secret"]), RpcArguments.Boolean(arguments["publishValueAsDefault"])); 83RpcArguments.Validate(arguments, ["context", "name", "typeId"]); 86var result = target.AddResource(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["typeId"])); 91RpcArguments.Validate(arguments, ["context", "name", "value"]); 94var result = target.AddSecretParameter(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["value"])); 99RpcArguments.Validate(arguments, ["context", "stream", "message"]); 101target.AppendResourceLog(RpcArguments.String(arguments["stream"]), RpcArguments.String(arguments["message"])); 106RpcArguments.Validate(arguments, ["context"]); 113RpcArguments.Validate(arguments, ["context", "target"]); 115target.BeginPublishing(RpcArguments.String(arguments["target"])); 120RpcArguments.Validate(arguments, ["context"]); 128RpcArguments.Validate(arguments, ["context"]); 135RpcArguments.Validate(arguments, ["context", "revision"]); 142RpcArguments.Validate(arguments, ["context", "failed"]); 144target.CompletePublishing(RpcArguments.Boolean(arguments["failed"])); 149RpcArguments.Validate(arguments, ["context", "requestId", "result"]); 151target.CompleteResourceCommand(RpcArguments.String(arguments["requestId"]), RpcArguments.Dto(arguments["result"], NativeRpcJsonContext.Default.RuntimeOperationResult)); 156RpcArguments.Validate(arguments, ["context", "revision", "result"]); 158target.CompleteResourceConfiguration(RpcArguments.Int64(arguments["revision"]), RpcArguments.Dto(arguments["result"], NativeRpcJsonContext.Default.RuntimeOperationResult)); 163RpcArguments.Validate(arguments, ["context", "suffix"]); 171RpcArguments.Validate(arguments, ["context", "graphJson"]); 173target.ConfigurePublishing(RpcArguments.String(arguments["graphJson"])); 178RpcArguments.Validate(arguments, ["context"]); 186RpcArguments.Validate(arguments, ["context"]); 194RpcArguments.Validate(arguments, ["context", "resource", "endpointName", "property"]); 197var result = target.CreateEndpointValue(handles.Get<DeclaredResource>(arguments["resource"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredResource"), RpcArguments.String(arguments["endpointName"]), RpcArguments.String(arguments["property"])); 202RpcArguments.Validate(arguments, ["context"]); 210RpcArguments.Validate(arguments, ["context", "value"]); 213var result = target.CreateLiteralValue(RpcArguments.String(arguments["value"])); 218RpcArguments.Validate(arguments, ["context"]); 226RpcArguments.Validate(arguments, ["context", "name", "displayName"]); 228target.DefineResourceCommand(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["displayName"])); 233RpcArguments.Validate(arguments, ["context"]); 241RpcArguments.Validate(arguments, ["context"]); 248RpcArguments.Validate(arguments, ["context"]); 256RpcArguments.Validate(arguments, ["context"]); 263RpcArguments.Validate(arguments, ["context"]); 270RpcArguments.Validate(arguments, ["context"]); 277RpcArguments.Validate(arguments, ["context"]); 284RpcArguments.Validate(arguments, ["context"]); 291RpcArguments.Validate(arguments, ["context"]); 298RpcArguments.Validate(arguments, ["context", "resource"]); 305RpcArguments.Validate(arguments, ["context", "resourceName", "commandName"]); 308var result = target.InvokeResourceCommand(RpcArguments.String(arguments["resourceName"]), RpcArguments.String(arguments["commandName"])); 313RpcArguments.Validate(arguments, ["context", "invitation"]); 316var result = target.JoinApplicationObserver(RpcArguments.String(arguments["invitation"])); 321RpcArguments.Validate(arguments, ["context", "invitation"]); 324var result = target.JoinApplicationWorkspace(RpcArguments.String(arguments["invitation"])); 329RpcArguments.Validate(arguments, ["context", "invitation"]); 332var result = target.JoinResourceExecution(RpcArguments.String(arguments["invitation"])); 337RpcArguments.Validate(arguments, ["context"]); 345RpcArguments.Validate(arguments, ["context", "observation"]); 347target.PublishObservation(RpcArguments.Dto(arguments["observation"], NativeRpcJsonContext.Default.ResourceObservation)); 352RpcArguments.Validate(arguments, ["context"]); 359RpcArguments.Validate(arguments, ["context"]); 366RpcArguments.Validate(arguments, ["context"]); 373RpcArguments.Validate(arguments, ["context"]); 380RpcArguments.Validate(arguments, ["context"]); 387RpcArguments.Validate(arguments, ["context"]); 394RpcArguments.Validate(arguments, ["context", "resourceId", "afterSequence"]); 396var result = target.ReadResourceLogs(RpcArguments.String(arguments["resourceId"]), RpcArguments.Int64(arguments["afterSequence"])); 401RpcArguments.Validate(arguments, ["context"]); 408RpcArguments.Validate(arguments, ["context", "name"]); 410target.RemoveSymbolicConfiguration(RpcArguments.String(arguments["name"])); 415RpcArguments.Validate(arguments, ["context", "step", "status", "complete", "failed"]); 417target.ReportPublishingActivity(RpcArguments.String(arguments["step"]), RpcArguments.String(arguments["status"]), RpcArguments.Boolean(arguments["complete"]), RpcArguments.Boolean(arguments["failed"])); 422RpcArguments.Validate(arguments, ["context", "step", "type", "id", "status", "complete", "failed", "markdown"]); 424target.ReportPublishingProgress(RpcArguments.String(arguments["step"]), RpcArguments.String(arguments["type"]), RpcArguments.String(arguments["id"]), RpcArguments.String(arguments["status"]), RpcArguments.Boolean(arguments["complete"]), RpcArguments.Boolean(arguments["failed"]), RpcArguments.Boolean(arguments["markdown"])); 429RpcArguments.Validate(arguments, ["context", "message"]); 432var result = target.RequestConfirmation(RpcArguments.String(arguments["message"])); 437RpcArguments.Validate(arguments, ["context", "requestId", "accepted"]); 439target.RespondConfirmation(RpcArguments.String(arguments["requestId"]), RpcArguments.Boolean(arguments["accepted"])); 444RpcArguments.Validate(arguments, ["context", "revision", "container"]); 446var result = await target.RestartContainer(RpcArguments.Int64(arguments["revision"]), RpcArguments.Dto(arguments["container"], NativeRpcJsonContext.Default.ContainerLaunch)).ConfigureAwait(false); 451RpcArguments.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]); 453var result = await target.RestartContainerWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.String(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false); 458RpcArguments.Validate(arguments, ["context", "revision", "launch"]); 460var result = await target.RestartContainerWorkload(RpcArguments.Int64(arguments["revision"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch)).ConfigureAwait(false); 465RpcArguments.Validate(arguments, ["context", "revision", "executable"]); 467var result = await target.RestartExecutable(RpcArguments.Int64(arguments["revision"]), RpcArguments.Dto(arguments["executable"], NativeRpcJsonContext.Default.ExecutableLaunch)).ConfigureAwait(false); 472RpcArguments.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]); 474var result = await target.RestartExecutableWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.String(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false); 479RpcArguments.Validate(arguments, ["context", "revision", "launch"]); 481var result = await target.RestartExecutableWorkload(RpcArguments.Int64(arguments["revision"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch)).ConfigureAwait(false); 486RpcArguments.Validate(arguments, ["context"]); 493RpcArguments.Validate(arguments, ["context", "composition"]); 500RpcArguments.Validate(arguments, ["context", "launch", "bindings"]); 502var result = await target.RunLifecycleExecutable(RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false); 507RpcArguments.Validate(arguments, ["context"]); 514RpcArguments.Validate(arguments, ["context", "configuration"]); 516target.SetResourceConfiguration(RpcArguments.Dto(arguments["configuration"], NativeRpcJsonContext.Default.ResourceConfiguration)); 521RpcArguments.Validate(arguments, ["context", "name", "value"]); 523target.SetSymbolicConfiguration(RpcArguments.String(arguments["name"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue")); 528RpcArguments.Validate(arguments, ["context"]); 536RpcArguments.Validate(arguments, ["context", "container"]); 538var result = await target.StartContainer(RpcArguments.Dto(arguments["container"], NativeRpcJsonContext.Default.ContainerLaunch)).ConfigureAwait(false); 543RpcArguments.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]); 545var result = await target.StartContainerWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.String(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false); 550RpcArguments.Validate(arguments, ["context", "launch"]); 552var result = await target.StartContainerWorkload(RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ContainerWorkloadLaunch)).ConfigureAwait(false); 557RpcArguments.Validate(arguments, ["context", "executable"]); 559var result = await target.StartExecutable(RpcArguments.Dto(arguments["executable"], NativeRpcJsonContext.Default.ExecutableLaunch)).ConfigureAwait(false); 564RpcArguments.Validate(arguments, ["context", "revision", "networkContext", "launch", "bindings"]); 566var result = await target.StartExecutableWithValues(RpcArguments.Int64(arguments["revision"]), RpcArguments.String(arguments["networkContext"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)).ConfigureAwait(false); 571RpcArguments.Validate(arguments, ["context", "launch"]); 573var result = await target.StartExecutableWorkload(RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch)).ConfigureAwait(false); 578RpcArguments.Validate(arguments, ["context"]); 586RpcArguments.Validate(arguments, ["context", "timeoutMilliseconds"]); 588await target.WaitApplicationReady(RpcArguments.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false); 593RpcArguments.Validate(arguments, ["context", "dependency"]); 600RpcArguments.Validate(arguments, ["context"]); 607RpcArguments.Validate(arguments, ["context"]); 614RpcArguments.Validate(arguments, ["context", "timeoutMilliseconds"]); 616var result = await target.WaitResourceCommands(RpcArguments.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false); 621RpcArguments.Validate(arguments, ["context", "resource", "timeoutMilliseconds"]); 623var result = await target.WaitResourceCompletion(handles.Get<DeclaredResource>(arguments["resource"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredResource"), RpcArguments.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false); 628RpcArguments.Validate(arguments, ["context", "revision", "timeoutMilliseconds"]); 630var result = await target.WaitResourceConfiguration(RpcArguments.Int64(arguments["revision"]), RpcArguments.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false); 635RpcArguments.Validate(arguments, ["context", "version", "timeoutMilliseconds"]); 637var result = await target.WaitResourceObservations(RpcArguments.Int64(arguments["version"]), RpcArguments.Int32(arguments["timeoutMilliseconds"])).ConfigureAwait(false); 642RpcArguments.Validate(arguments, ["context", "value"]); 650RpcArguments.Validate(arguments, ["context", "source", "target", "readOnly"]); 653var result = target.WithBindMount(RpcArguments.String(arguments["source"]), RpcArguments.String(arguments["target"]), RpcArguments.Boolean(arguments["readOnly"])); 658RpcArguments.Validate(arguments, ["context", "environment"]); 665RpcArguments.Validate(arguments, ["context", "endpoint"]); 668var result = target.WithEndpoint(RpcArguments.Dto(arguments["endpoint"], NativeRpcJsonContext.Default.WorkloadEndpointDeclaration)); 673RpcArguments.Validate(arguments, ["context", "entrypoint"]); 676var result = target.WithEntrypoint(RpcArguments.String(arguments["entrypoint"])); 681RpcArguments.Validate(arguments, ["context", "name", "value"]); 684var result = target.WithEnvironment(RpcArguments.String(arguments["name"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue")); 689RpcArguments.Validate(arguments, ["context"]); 697RpcArguments.Validate(arguments, ["context", "phase", "launch", "bindings"]); 700var result = target.WithLifecycleExecutable(RpcArguments.String(arguments["phase"]), RpcArguments.Dto(arguments["launch"], NativeRpcJsonContext.Default.ExecutableWorkloadLaunch), RpcArguments.Dto(arguments["bindings"], NativeRpcJsonContext.Default.SymbolicLaunchBindings)); 705RpcArguments.Validate(arguments, ["context", "environmentName", "value"]); 708var result = target.WithReference(RpcArguments.String(arguments["environmentName"]), handles.Get<DeclaredValue>(arguments["value"], "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue")); 713RpcArguments.Validate(arguments, ["context", "name", "target", "readOnly"]); 716var result = target.WithVolume(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["target"]), RpcArguments.Boolean(arguments["readOnly"])); 721RpcArguments.Validate(arguments, ["context", "stream", "message"]); 723target.WriteLifecycleLog(RpcArguments.String(arguments["stream"]), RpcArguments.String(arguments["message"])); 728RpcArguments.Validate(arguments, ["context", "value"]); 730target.Add(RpcArguments.Union(arguments["value"], handles, ["Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEndpoint", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcResource"])); 735RpcArguments.Validate(arguments, ["context", "name", "image"]); 738var result = target.AddContainer(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["image"])); 743RpcArguments.Validate(arguments, ["context", "name", "executablePath", "workingDirectory"]); 746var result = target.AddExecutable(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["executablePath"]), RpcArguments.String(arguments["workingDirectory"])); 751RpcArguments.Validate(arguments, ["context", "name", "value"]); 754var result = target.AddSecretParameter(RpcArguments.String(arguments["name"]), RpcArguments.String(arguments["value"])); 759RpcArguments.Validate(arguments, ["context"]); 767RpcArguments.Validate(arguments, ["context", "name"]); 770var result = target.GetEndpoint(RpcArguments.String(arguments["name"])); 775RpcArguments.Validate(arguments, ["context"]); 782RpcArguments.Validate(arguments, ["context", "annotationId"]); 784var result = target.GetSerializedAnnotation(RpcArguments.String(arguments["annotationId"])); 789RpcArguments.Validate(arguments, ["context", "property"]); 792var result = target.Property(RpcArguments.String(arguments["property"])); 797RpcArguments.Validate(arguments, ["context"]); 804RpcArguments.Validate(arguments, ["context", "name", "value"]); 806target.Set(RpcArguments.String(arguments["name"]), RpcArguments.Union(arguments["value"], handles, ["Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEndpoint", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcResource"])); 811RpcArguments.Validate(arguments, ["context", "dependency"]); 819RpcArguments.Validate(arguments, ["context", "args"]); 822var result = target.WithArgs(RpcArguments.Strings(arguments["args"])); 827RpcArguments.Validate(arguments, ["context", "callback"]); 829var result = await target.WithArgsCallback(connection.CreateAuthoringCallback<RpcArgsEditor>(callbackConnection, RpcArguments.String(arguments["callback"]), "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcArgsEditor")).ConfigureAwait(false); 834RpcArguments.Validate(arguments, ["context", "value"]); 837var result = target.WithConnectionString(RpcArguments.Union(arguments["value"], handles, ["Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEndpoint", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcResource"])); 842RpcArguments.Validate(arguments, ["context", "options"]); 845var result = target.WithEndpoint(RpcArguments.Dto(arguments["options"], NativeRpcJsonContext.Default.RpcEndpointOptions)); 850RpcArguments.Validate(arguments, ["context", "name", "value"]); 853var result = target.WithEnvironment(RpcArguments.String(arguments["name"]), RpcArguments.Union(arguments["value"], handles, ["Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Api.DeclaredValue", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEndpoint", "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcResource"])); 858RpcArguments.Validate(arguments, ["context", "callback"]); 860var result = await target.WithEnvironmentCallback(connection.CreateAuthoringCallback<RpcEnvironmentEditor>(callbackConnection, RpcArguments.String(arguments["callback"]), "Aspire.Hosting.Native.Server/Aspire.Hosting.Native.Authoring.RpcEnvironmentEditor")).ConfigureAwait(false); 865RpcArguments.Validate(arguments, ["context", "tag"]); 868var result = target.WithImageTag(RpcArguments.String(arguments["tag"])); 873RpcArguments.Validate(arguments, ["context", "source"]); 881RpcArguments.Validate(arguments, ["context", "annotationId", "json"]); 884var result = target.WithSerializedAnnotation(RpcArguments.String(arguments["annotationId"]), RpcArguments.String(arguments["json"])); 889RpcArguments.Validate(arguments, []);
Rpc\NativeHandles.cs (6)
51RpcArguments.Validate(reference, ["$handle", "$type"]); 52var id = RpcArguments.String(reference["$handle"]); 53var typeId = RpcArguments.String(reference["$type"]); 68RpcArguments.Validate(reference, ["$handle", "$type"]); 69var id = RpcArguments.String(reference["$handle"]); 70var typeId = RpcArguments.String(reference["$type"]);
Rpc\NativeProviderMetadata.cs (6)
50result[index] = new(RpcArguments.String(metadata["id"]), RpcArguments.String(metadata["method"]), 64var name = RpcArguments.String(argument["name"]); 91new(RpcArguments.String(type["typeId"]), RpcArguments.String(type["category"]) switch 100metadata[name] is { } value ? RpcArguments.String(value) : null;
Rpc\NativeProviderRegistry.cs (4)
211RpcArguments.Validate(arguments, parameters.Select(parameter => parameter.Name).ToArray()); 222var callbackId = RpcArguments.String(arguments[name]); 344RpcArguments.String(handle["$type"])); 369RpcArguments.Validate(arguments, Enumerable.Range(0, parameters.Length).Select(index => $"p{index}").ToArray());
Rpc\NativeProviderValueProtocol.cs (7)
16case NativeProviderValueKind.String: _ = RpcArguments.String(value); return; 17case NativeProviderValueKind.Boolean: _ = RpcArguments.Boolean(value); return; 18case NativeProviderValueKind.Int32: _ = RpcArguments.Int32(value); return; 19case NativeProviderValueKind.Int64: _ = RpcArguments.Int64(value); return; 30RpcArguments.Validate(handle, core ? ["$handle", "$type"] : ["$handle", "$type", "$lifetime"]); 31var id = RpcArguments.String(handle["$handle"]); 32if (id.Length is 0 or > 512 || RpcArguments.String(handle["$type"]) != type.TypeId)
Rpc\NativeRpcConnection.cs (2)
76DelegatedCoreReference delegated => (delegated.Owner, RpcArguments.String(delegated.Handle["$handle"]), typeId), 77ProviderResourceReference resource => (resource.Provider.Connection, RpcArguments.String(resource.Handle["$handle"]), typeId),
Rpc\NativeRpcConnection.Dispatch.cs (9)
18var supplied = Encoding.UTF8.GetBytes(RpcArguments.String(authentication[0])); 76? _languages.RuntimeSpec(RpcArguments.String(arguments[0])) 77: _languages.GeneratedSdk(RpcArguments.String(arguments[0])); 86var capabilityId = RpcArguments.String(arguments[0]); 117return JsonValue.Create(_providers.Expect(this, RpcArguments.String(expectation[0]))); 123await _providers.RegisterAsync(this, RpcArguments.String(registration[0]), _peer).ConfigureAwait(false); 130await _providers.WaitRegistrationAsync(this, RpcArguments.String(activation[0])).ConfigureAwait(false); 137return JsonValue.Create(_providers.AbandonRegistration(this, RpcArguments.String(abandonment[0]))); 143return await _providers.InvokeCallbackAsync(this, RpcArguments.String(callback[0]), callbackArguments).ConfigureAwait(false);