Class BroadcastOperator

packages/socket.io-postgres-emitter/lib/index.ts:248–536

]);

export class BroadcastOperator<
  EmitEvents extends EventsMap,
  ServerSideEvents extends EventsMap,
> implements TypedEventBroadcaster<EmitEvents>
{
  constructor(
    private readonly emitter: Emitter,
    private readonly rooms: Set<string> = new Set<string>(),
    private readonly exceptRooms: Set<string> = new Set<string>(),
    private readonly flags: BroadcastFlags = {},
  ) {}

  /**
   * Targets a room when emitting.
   *
   * @param room
   * @return a new BroadcastOperator instance
   * @public
   */
  public to(
    room: string | string[],
  ): BroadcastOperator<EmitEvents, ServerSideEvents> {
    const rooms = new Set(this.rooms);
    if (Array.isArray(room)) {
      room.forEach((r) => rooms.add(r));
    } else {
      rooms.add(room);
    }
    return new BroadcastOperator(
      this.emitter,
      rooms,
      this.exceptRooms,
      this.flags,
    );
  }

  /**
   * Targets a room when emitting.
   *
   * @param room
   * @return a new BroadcastOperator instance
   * @public
   */
  public in(
    room: string | string[],
  ): BroadcastOperator<EmitEvents, ServerSideEvents> {
    return this.to(room);
  }

  /**
   * Excludes a room when emitting.
   *
   * @param room
   * @return a new BroadcastOperator instance
   * @public
   */
  public except(
    room: string | string[],