constructor()

in src/directLineStreaming.ts [109:128]

• 15 lines of code
• 2 McCabe index (conditional complexity)

  constructor(options: DirectLineStreamingOptions) {
    this.token = options.token;

    this.refreshToken();

    this.domain = options.domain;

    if (options.conversationId) {
      this.conversationId = options.conversationId;
    }

    this._botAgent = this.getBotAgent(options.botAgent);

    this.queueActivities = true;
    this.activity$ = Observable.create(async (subscriber: Subscriber<Activity>) => {
      this.activitySubscriber = subscriber;
      this.theStreamHandler = new StreamHandler(subscriber, this.connectionStatus$, () => this.queueActivities);
      this.connectWithRetryAsync();
    }).share();
  }