mirror of
https://code.equilibrium.co.ao/ITO/doneit-web.git
synced 2026-04-19 21:06:06 +00:00
add subscribe
This commit is contained in:
@@ -62,7 +62,7 @@ class _RocketChatClientService {
|
||||
return new Promise((resolve, reject) => {
|
||||
this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
|
||||
// console.log(message.result.id, requestId)
|
||||
if(message.id == requestId) { // same request send
|
||||
if(message.id == requestId || message.result.id == requestId) { // same request send
|
||||
if(message.result) {
|
||||
if(message.result.token) {
|
||||
this.isLogin = true
|
||||
@@ -120,7 +120,7 @@ class _RocketChatClientService {
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
|
||||
if(message.result.id == requestId) { // same request send
|
||||
if(message.id == requestId || message.result.id == requestId) { // same request send
|
||||
resolve(message)
|
||||
}
|
||||
}})
|
||||
@@ -141,7 +141,7 @@ class _RocketChatClientService {
|
||||
}
|
||||
|
||||
this.ws.send(subscribeRequest);
|
||||
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
this.ws.registerCallback({type:'Onmessage', requestId, runOnces: true, funx:(message)=>{
|
||||
if(message.result.id == requestId) { // same request send
|
||||
|
||||
Reference in New Issue
Block a user