TopicSubscription.subject constructor

@visibleForTesting TopicSubscription.subject(Topic<Object> topic, String subscriptionId, BehaviorSubject<TopicSubscriptionState> stateSubject)

Implementation

@visibleForTesting
TopicSubscription.subject(this.topic, this.subscriptionId, this.stateSubject);