public stream()

in src/connectors/sql-stream-connector.ts [18:27]

• 10 lines of code
• 3 McCabe index (conditional complexity)

  public stream(query?: string) {
    query = query || this.config.query;
    if (!query) {
      throw new Error('query cannot be null or empty');
    }
    return this.client
      .raw(query)
      .stream()
      .on('end', () => this.client.destroy());
  }