Method attachSink

packages/telemetry/src/client.ts:41–58

(sink: EventSink)

  }

  attachSink(sink: EventSink): void {
    if (this.sink !== null && this.sink !== sink) {
      this.sink.stopPeriodicFlush();
      this.sink.flushSync();
    }
    this.sink = sink;
    for (const event of this.queue) {
      const record = toTelemetryEvent(event);
      if (record.device_id === null && event.contextOverrides?.deviceId !== true) {
        record.device_id = this.deviceId;
      }
      if (record.session_id === null && event.contextOverrides?.sessionId !== true) {
        record.session_id = this.sessionId;
      }
      sink.accept(record);
    }
    this.queue = [];
  }

  disable(): void {
    this.disabled = true;