import { Observable } from '../observable' ; import { FluxTableMetaData , Row } from './FluxTableMetaData' ; import { CommunicationObserver } from './CommunicationObserver' ; import { FluxResultObserver } from './FluxResultObserver' ; /**
 * AnnotatedCSVResponse provides various ways of how to
 * process data from an annotated CSV response stream,
 * which is returned as a result of a flux script execution.
 */ export interface AnnotatedCSVResponse { returns lines ( ) : Observable < string > ; returns rows ( ) : Observable < Row > ; param consumer consumeLines ( consumer ) : void ; param consumer consumeRows ( consumer ) : void ; param rowMapper returns collectRows < T > ( rowMapper ? ) : Promise < Array < T > > ; returns collectLines ( ) : Promise < Array < string > > ; }