925
return getDelayedChannel(channelPromise)
926
.listen(event, arg);
928
>
} as T;
929
>
}
930
931
private getMulticastEvent<T extends IChannel>(channelName: string, clientFilter: (client: Client<TContext>) => boolean, eventName: string, arg: any): Event<T> {
932
>
const that = this;
ipc.ts
933
>
let disposables: DisposableStore | undefined;
934
>
935
>
// Create an emitter which hooks up to all clients
936
>
// as soon as first listener is added. It also
937
>
// disconnects from all clients as soon as the last listener
938
>
// is removed.
939
>
const emitter = new Emitter<T>({
940
>
onWillAddFirstListener: () => {
941
>
disposables = new DisposableStore();
942
>
943
>
// The event multiplexer is useful since the active
944
>
// client list is dynamic. We need to hook up and disconnection
945
>
// to/from clients as they come and go.
946
>
const eventMultiplexer = new EventMultiplexer<T>();
947
>
const map = new Map<Connection<TContext>, IDisposable>();
948
>
949
>
const onDidAddConnection = (connection: Connection<TContext>) => {
950
>
const channel = connection.channelClient.getChannel(channelName);
951
>
const event = channel.listen<T>(eventName, arg);
952
>
const disposable = eventMultiplexer.add(event);
953
>
954
>
map.set(connection, disposable);
955
>
};
956
>
957
>
const onDidRemoveConnection = (connection: Connection<TContext>) => {
958
>
const disposable = map.get(connection);
959
>
960
>
if (!disposable) {
961
return;
962
}
964
>
disposable.dispose();
965
>
map.delete(connection);
966
>
};
967
>
968
>
that.connections.filter(clientFilter).forEach(onDidAddConnection);
969
>
Event.filter(that.onDidAddConnection, clientFilter)(onDidAddConnection, undefined, disposables);
970
>
that.onDidRemoveConnection(onDidRemoveConnection, undefined, disposables);
971
>
eventMultiplexer.event(emitter.fire, emitter, disposables);
972
>
973
>
disposables.add(eventMultiplexer);
974
>
},
975
>
onDidRemoveLastListener: () => {
976
>
disposables?.dispose();
977
>
disposables = undefined;
978
>
}
979
>
});
980
>
that.disposables.add(emitter);
981
>
982
>
return emitter.event;
983
>
}
984
985
registerChannel(channelName: string, channel: IServerChannel<TContext>): void {