MCPcopy Index your code
hub / github.com/parse-community/parse-server / Publisher

Class Publisher

src/Adapters/MessageQueue/EventEmitterMQ.js:16–26  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

14}
15
16class Publisher {
17 emitter: any;
18
19 constructor(emitter: any) {
20 this.emitter = emitter;
21 }
22
23 publish(channel: string, message: string): void {
24 this.emitter.emit(channel, message);
25 }
26}
27
28class Consumer extends events.EventEmitter {
29 emitter: any;

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected