Home Reference Source

References

summary
public

Rxmq channel class

public

C Rxmq

Rxmq message bus class

rx

summary
public

EndlessReplaySubject extension of ReplaySubject.

public

EndlessSubject extension of Rx.Subject.

utils

summary
private

F compareTopics(topic: String, existingTopic: String): Boolean

Compares given topic with existing topic

public

F findSubjectByName(subjects: Array, name: String): EndlessSubject | void

Find a specific subject by given name

Directories