Lines Matching defs:channel
57 function markActive(channel) {
59 ObjectSetPrototypeOf(channel, ActiveChannel.prototype);
60 channel._subscribers = [];
61 channel._stores = new SafeMap();
64 function maybeMarkInactive(channel) {
66 if (!channel._subscribers.length && !channel._stores.size) {
68 ObjectSetPrototypeOf(channel, Channel.prototype);
69 channel._subscribers = undefined;
70 channel._stores = undefined;
94 // TODO(qard): should there be a C++ channel interface?
212 function channel(name) {
213 const channel = channels.get(name);
214 if (channel) return channel;
217 throw new ERR_INVALID_ARG_TYPE('channel', ['string', 'symbol'], name);
224 return channel(name).subscribe(subscription);
228 return channel(name).unsubscribe(subscription);
232 const channel = channels.get(name);
233 if (!channel) return false;
235 return channel.hasSubscribers;
255 this.start = channel(`tracing:${nameOrChannels}:start`);
256 this.end = channel(`tracing:${nameOrChannels}:end`);
257 this.asyncStart = channel(`tracing:${nameOrChannels}:asyncStart`);
258 this.asyncEnd = channel(`tracing:${nameOrChannels}:asyncEnd`);
259 this.error = channel(`tracing:${nameOrChannels}:error`);
407 channel,