add peerWs emit
This commit is contained in:
parent
355dc574f8
commit
e2854ca9b1
1
dist/src/instance.js
vendored
1
dist/src/instance.js
vendored
@ -33,6 +33,7 @@ const createInstance = ({ app, server, options }) => {
|
|||||||
config: customConfig
|
config: customConfig
|
||||||
});
|
});
|
||||||
app.set('peerWs', wss);
|
app.set('peerWs', wss);
|
||||||
|
app.emit('peerWs', wss);
|
||||||
wss.on("connection", (client) => {
|
wss.on("connection", (client) => {
|
||||||
const messageQueue = realm.getMessageQueueById(client.getId());
|
const messageQueue = realm.getMessageQueueById(client.getId());
|
||||||
if (messageQueue) {
|
if (messageQueue) {
|
||||||
|
@ -46,6 +46,7 @@ export const createInstance = ({ app, server, options }: {
|
|||||||
});
|
});
|
||||||
|
|
||||||
app.set('peerWs', wss);
|
app.set('peerWs', wss);
|
||||||
|
app.emit('peerWs', wss);
|
||||||
|
|
||||||
wss.on("connection", (client: IClient) => {
|
wss.on("connection", (client: IClient) => {
|
||||||
const messageQueue = realm.getMessageQueueById(client.getId());
|
const messageQueue = realm.getMessageQueueById(client.getId());
|
||||||
|
Loading…
x
Reference in New Issue
Block a user