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> {
// имплементация трансфера
}
}
Имплементирует
Partial
<TransportDriver
>
Конструкторы
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