references: add offset to pull

Refs: #23
Fishrock123 · Jun 5, 2019 · 7e1b0b7 · 7e1b0b7
1 parent 679c9e5
commit 7e1b0b7
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 6 deletions.
diff --git a/reference-buffered-transform.js b/reference-buffered-transform.js
@@ -55,7 +55,7 @@ class BufferedTransform {
  }
  }
 
- pull (error, buffer) {
+ pull (error, buffer /*, offset */) {
  if (this._bytes === 0) {
  return this.source.pull(error, buffer)
  }

diff --git a/reference-extension-start.js b/reference-extension-start.js
@@ -15,7 +15,7 @@ class StartExtensionSink extends Sink {
  // sink handles buffer allocation
  const buffer = new Buffer(0)
 
- this.source.pull(null, buffer)
+ this.source.pull(null, buffer, 0)
  }
 }
 

diff --git a/reference-passthrough.js b/reference-passthrough.js
@@ -21,8 +21,8 @@ class PassThrough {
  this.sink.next(status, error, buffer, bytes)
  }
 
- pull (error, buffer) {
- this.source.pull(error, buffer)
+ pull (error, buffer, offset) {
+ this.source.pull(error, buffer, offset)
  }
 }
 

diff --git a/reference-sink.js b/reference-sink.js
@@ -23,7 +23,7 @@ class Sink {
  // sink handles buffer allocation
  const buffer = new Buffer(0)
 
- this.source.pull(null, buffer)
+ this.source.pull(null, buffer, 0)
  }
 
  next (status, error, buffer, bytes) {

diff --git a/reference-source.js b/reference-source.js
@@ -12,9 +12,10 @@ class Source {
  this.sink = sink
  }
 
- pull (error, buffer) {
+ pull (error, buffer, offset) {
  // error MUST be null or an error
  // buffer MUST be a Buffer
+ // if offset exists, use it if possible
  if (error || sourceError) {
  return this.sink.next(status_type.error, error)
  }