@@ -38,44 +38,44 @@ export function createRuntimeDirectoryLiveAdapter<Runtime>(params: {
3838runtime: Runtime,
3939) => ChannelDirectoryAdapter["listGroupMembers"] | null | undefined;
4040}): Pick<ChannelDirectoryAdapter, DirectoryMethod> {
41-return {
42- self: params.self
43- ? async (ctx: DirectorySelfParams) =>
44- await (
45- await resolveForwardedMethod({
46- getRuntime: params.getRuntime,
47- resolve: params.self!,
48- })
49- )(ctx)
50- : undefined,
51- listPeersLive: params.listPeersLive
52- ? async (ctx: DirectoryListParams) =>
53- await (
54- await resolveForwardedMethod({
55- getRuntime: params.getRuntime,
56- resolve: params.listPeersLive!,
57- })
58- )(ctx)
59- : undefined,
60- listGroupsLive: params.listGroupsLive
61- ? async (ctx: DirectoryListParams) =>
62- await (
63- await resolveForwardedMethod({
64- getRuntime: params.getRuntime,
65- resolve: params.listGroupsLive!,
66- })
67- )(ctx)
68- : undefined,
69- listGroupMembers: params.listGroupMembers
70- ? async (ctx: DirectoryGroupMembersParams) =>
71- await (
72- await resolveForwardedMethod({
73- getRuntime: params.getRuntime,
74- resolve: params.listGroupMembers!,
75- })
76- )(ctx)
77- : undefined,
78-};
41+const adapter: Pick<ChannelDirectoryAdapter, DirectoryMethod> = {};
42+if (params.self) {
43+adapter.self = async (ctx: DirectorySelfParams) =>
44+await (
45+await resolveForwardedMethod({
46+getRuntime: params.getRuntime,
47+resolve: params.self!,
48+})
49+)(ctx);
50+}
51+if (params.listPeersLive) {
52+adapter.listPeersLive = async (ctx: DirectoryListParams) =>
53+await (
54+await resolveForwardedMethod({
55+getRuntime: params.getRuntime,
56+resolve: params.listPeersLive!,
57+})
58+)(ctx);
59+}
60+if (params.listGroupsLive) {
61+adapter.listGroupsLive = async (ctx: DirectoryListParams) =>
62+await (
63+await resolveForwardedMethod({
64+getRuntime: params.getRuntime,
65+resolve: params.listGroupsLive!,
66+})
67+)(ctx);
68+}
69+if (params.listGroupMembers) {
70+adapter.listGroupMembers = async (ctx: DirectoryGroupMembersParams) =>
71+await (
72+await resolveForwardedMethod({
73+getRuntime: params.getRuntime,
74+resolve: params.listGroupMembers!,
75+})
76+)(ctx);
77+}
78+return adapter;
7979}
80808181export function createRuntimeOutboundDelegates<Runtime>(params: {
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。