<protected> new CSVStream()
CSVStream (extends RecordStream implements Receivable, Sendable)
- Source:
Extends
Methods
-
destroy()
-
Destroy record stream;
- Inherited From:
- Source:
-
destroySoon()
-
Destroy record stream after all record submission in the queue;
- Inherited From:
- Source:
-
end(record)
-
Parameters:
Name Type Description record
Record Record object - Source:
-
filter(fn) → {RecordStream}
-
Filtering incoming record from upstream, and pass to downstream
Parameters:
Name Type Description fn
RecordFilterFunction Record filtering function - Inherited From:
- Source:
Returns:
- Type
- RecordStream
-
map(fn) → {RecordStream}
-
Mapping incoming record from upstream, and pass to downstream
Parameters:
Name Type Description fn
RecordMapFunction Record mapping function - Inherited From:
- Source:
Returns:
- Type
- RecordStream
-
pipe(dest, options) → {RecordStream}
-
Streaming pipe for record manipulation Originally from Node.js's Stream#pipe https://github.com/joyent/node/blob/master/lib/stream.js
Parameters:
Name Type Argument Description dest
RecordStream Destination output stream for records options
Object <optional>
- Inherited From:
- Source:
Returns:
- Type
- RecordStream
-
<abstract> resume()
-
Resume record fetch and query execution
- Inherited From:
- Source:
-
send(record)
-
Parameters:
Name Type Description record
Record Record object - Source:
-
stream()
-
Get delegating Node.js stream
- Source: