Anjing Webshells

Website : rimsha.abasa.com
: / var / canvas / node_modules / @canvas / tour-pubsub /
Filename : pubsub.ts
back
/*
 * Copyright (C) 2020 - present Instructure, Inc.
 *
 * This file is part of Canvas.
 *
 * Canvas is free software: you can redistribute it and/or modify it under
 * the terms of the GNU Affero General Public License as published by the Free
 * Software Foundation, version 3 of the License.
 *
 * Canvas is distributed in the hope that it will be useful, but WITHOUT ANY
 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
 * A PARTICULAR PURPOSE. See the GNU Affero General Public License for more
 * details.
 *
 * You should have received a copy of the GNU Affero General Public License along
 * with this program. If not, see <http://www.gnu.org/licenses/>.
 */

// A simple pubsub engine for sending messages between Canvas components
import {v4 as uuidv4} from 'uuid'

type Callback<T> = (args: T) => void | null

export default class PubSub {
  topics: Record<string, Record<string, Callback<any>>> = {}

  subscribe<T>(topic: string, fn: Callback<T>): () => void {
    if (!this.topics[topic]) this.topics[topic] = {}
    const id = uuidv4()
    this.topics[topic][id] = fn
    return () => {
      delete this.topics[topic][id]
    }
  }

  publish(topic: string, args?: unknown): void {
    if (!this.topics[topic]) return
    Object.values(this.topics[topic]).forEach(fn => {
      if (fn) fn(args)
    })
  }
}