export function getStreamReader()

in src/stream/reader.ts [6:15]

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

export function getStreamReader(type: string, config: any) {
  switch (type) {
    case 'sql':
      return sqlStreamReader(config);
    case 'json':
      return jsonStreamReader(config);
    default:
      throw new Error(`Invalid input type ${type}`);
  }
}