Global Event Bus

Usage

Global event bus is provided by the sdk.

Example usage:

import getSDK from '@akashaorg/awf-sdk';
import { filter } from 'rxjs';
import { GlobalEventBusData, WEB3_EVENTS } from '@akashaorg/typings/lib/sdk';

// get the event bus
const globalChannel = getSDK().api.globalChannel;

// filter the events
const observable = globalChannel.pipe(filter(data => data.event === WEB3_EVENTS.CHAIN_CHANGED));

// subscribe to data
const subscription = observable.subscribe((event: GlobalEventBusData<{ chainId: number }>) => {
  // chaindId = event.data.chainId;
});

// afterwards, when you are done with the subscription
// you can also unsubscribe it

// subscription.unsubscribe();

Classes

EventBus

Extends

• ReplaySubject<GlobalEventBusData>

Constructors

new EventBus()

new EventBus(size?, time?, timeStampProvider?): EventBus

Parameters

Parameter	Type
size?	number
time?	number
timeStampProvider?	TimestampProvider

Returns

EventBus

Overrides

ReplaySubject<GlobalEventBusData>.constructor

Source

event-bus.ts:9