lib/Thenstream.js
function onReadable() {
    if (self._assimilationState.waiting) {
      self._assimilationState.waiting = false;
      self._pushChunks();
    }
  }
function onReadable() {
    if (self._assimilationState.waiting) {
      self._assimilationState.waiting = false;
      self._pushChunks();
    }
  }
function onReadable ( ) { if ( self . _assimilationState . waiting ) { self . _assimilationState . waiting = false ; self . _pushChunks ( ) ; } }
Push more chunks when data becomes available.
Push more chunks when data becomes available .