backend/business-management/bin/tools/broker/PubSubBroker.js
/**
     * Creates a Topic and return an observable that resolves to the created topic
     * @param {string} topicName 
     */
Creates a Topic and return an observable that resolves to the created topic
@param {string} topicName
Creates a Topic and return an observable that resolves to the created topic @param { string } topicName
createTopic$(topicName) {
        return Rx.Observable.fromPromise(this.pubsubClient.createTopic(topicName))
            .switchMap(data => {
                this.verifiedTopics[topicName] = this.pubsubClient.topic(topicName);
                return Rx.Observable.of(this.verifiedTopics[topicName]);
            });
    }
createTopic$ ( topicName ) { return Rx . Observable . fromPromise ( this . pubsubClient . createTopic ( topicName ) ) . switchMap ( data => { this . verifiedTopics [ topicName ] = this . pubsubClient . topic ( topicName ) ; return Rx . Observable . of ( this . verifiedTopics [ topicName ] ) ; } ) ; }
Creates a Topic and return an observable that resolves to the created topic
 @param {string} topicName
Creates a Topic and return an observable that resolves to the created topic @param { string } topicName