chat service checked
This commit is contained in:
parent
c00d9ba51d
commit
2d95b38a85
1 changed files with 2 additions and 0 deletions
|
|
@ -49,6 +49,7 @@ export class ChatService {
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
else{
|
else{
|
||||||
|
//console.log('sendMessage private: ',sender,receiver,message);
|
||||||
// @ts-ignore
|
// @ts-ignore
|
||||||
this.socket.emit('privateroom', {
|
this.socket.emit('privateroom', {
|
||||||
sender: sender,
|
sender: sender,
|
||||||
|
|
@ -64,6 +65,7 @@ export class ChatService {
|
||||||
}
|
}
|
||||||
|
|
||||||
onNewMessage(room: string): Observable<ChatInfo[]> {
|
onNewMessage(room: string): Observable<ChatInfo[]> {
|
||||||
|
//console.log('onNewMessage: ',room);
|
||||||
return new Observable(observer => {
|
return new Observable(observer => {
|
||||||
// @ts-ignore
|
// @ts-ignore
|
||||||
this.socket.on(room, (data: ChatInfo[]) => {
|
this.socket.on(room, (data: ChatInfo[]) => {
|
||||||
|
|
|
||||||
Reference in a new issue