import {EventBus, Subscribe} from "eventbus-ts";

class DataEvent extends EventBus.Event<string> {}
class NumEvent extends EventBus.Event<number> {}

class DisconnectEvent extends EventBus.Event<string> {
    getData(): string {
        return 'Disconnecting... ' + this.data;
    }
}

@Subscribe('DataEvent')
onDataEvent(data: string) : void {
    /* process data from DataEvent */
}

class Activity {
    constructor() {
        EventBus.getDefault().register(this);
    }
 
    @Subscribe('DataEvent')
    onDataEvent(data: string) : void {
        /* process data from DataEvent */
    }
 
    @Subscribe('NumEvent')
    onNumEvent(data: number): void {
        /* process data from NumEvent */
    }
}

EventBus.getDefault().post(new DataEvent('sync up!'));
EventBus.getDefault().post(new NumEvent(299792458));