socket channel
This commit is contained in:
@@ -3,12 +3,13 @@ import { io, Socket } from 'socket.io-client';
|
||||
import { BehaviorSubject, Observable, Subject } from 'rxjs';
|
||||
import { environment } from 'src/environments/environment';
|
||||
import { MarketDataService } from '../store/market-data.service'
|
||||
import {SessionDataProviderService} from "../store/session-data-provider.service";
|
||||
@Injectable({
|
||||
providedIn: 'root'
|
||||
})
|
||||
export class SocketToolsService {
|
||||
|
||||
constructor(public marketDataService: MarketDataService ) {
|
||||
constructor(public marketDataService: MarketDataService , public sessionDataProviderService:SessionDataProviderService) {
|
||||
// this.setup('NO-NEED-FOR-NOW');
|
||||
}
|
||||
private socket: Socket;
|
||||
@@ -24,7 +25,9 @@ export class SocketToolsService {
|
||||
}
|
||||
|
||||
public familyInvite(item){
|
||||
|
||||
console.log(item);
|
||||
let Vv = this.sessionDataProviderService.getFamilyRoom()+"-"+item.uid;
|
||||
this.emmitSocketEvent("send_message",item, Vv);
|
||||
}
|
||||
public joinSocketRoom(socketRoom){
|
||||
this.socket.emit("join_room", socketRoom);
|
||||
|
||||
Reference in New Issue
Block a user