Перейти к содержанию

Class: SimpleTransportDriver

Простое in-memory отслеживание подписок

Отслеживает подписки с помощью внутреннего Map объекта, это субоптимально, однако достаточно для простых кейсов.

Пример

export class TestTransportDriver extends SimpleTransportDriver implements TransportDriver {
  constructor() {
    super();

    // имплементация подписки
    this.emit(meta, data);
  }

  public async send(meta: TransportMeta, data: TransportData): Promise<void> {
    // имплементация трансфера
  }
}

Имплементирует

Конструкторы

constructor

new SimpleTransportDriver()

Методы

emit

emit(meta, data): Promise<void>

Параметры

Имя Тип
meta TransportMeta
data unknown

Возвращает

Promise<void>


off

off(id, data?): void

Параметры

Имя Тип
id string
data? unknown

Возвращает

void

Имплементация

Partial.off


on

on(filter, callback): string

Параметры

Имя Тип
filter Partial<TransportMeta>
callback TransportCallback

Возвращает

string

Имплементация

Partial.on