Class: CSVStream

RecordStream. CSVStream

<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: