import { Injectable } from '@nestjs/common';
import { Subject, Observable } from 'rxjs';

@Injectable()
export class SseHubService {
  private readonly eventSubject = new Subject<any>();
  private readonly scoreboardSubject = new Subject<any>();

  emitEvent(payload: any): void {
    this.eventSubject.next(payload);
  }

  emitScoreboard(payload: any): void {
    this.scoreboardSubject.next(payload);
  }

  event$(): Observable<any> {
    return this.eventSubject.asObservable();
  }

  scoreboard$(): Observable<any> {
    return this.scoreboardSubject.asObservable();
  }
}