Clean up with ESLint.

Author: soareschen

Diff for: src/lib/checksum.js

@@ -1,3 +1,4 @@
+import { error } from 'quiver-core/util/error'
 import { createHash, getHashes } from 'crypto'
 import { extract } from 'quiver-core/util/immutable'
 import { simpleHandlerBuilder } from 'quiver-core/component/constructor'
@@ -33,8 +34,8 @@ config => {
   const checksumField = 'checksum-' + checksumAlgorithm
 
   if(getHashes().indexOf(checksumAlgorithm) == -1)
-    return reject(error(500, 'platform do not ' +
-      'support checksum algorithm ' + checksumAlgorithm))
+    throw error(500, 'platform do not ' +
+      'support checksum algorithm ' + checksumAlgorithm)
 
   return (args, streamable) =>
     checksumStreamable(streamable, checksumAlgorithm, checksumField)

Diff for: src/lib/chunked.js

@@ -9,7 +9,7 @@ import {
   extractStreamHead, extractFixedStreamHead
 } from './head'
 
-const pipeChunkedStream = async function(readStream, writeStream, options={}) {
+const pipeChunkedStream = async function(readStream, writeStream) {
   try {
     while(true) {
       const { closed: writeClosed } = await writeStream.prepareWrite()
@@ -86,7 +86,7 @@ const pipeChunk = async function(readStream, writeStream, size) {
   }
 }
 
-const pipeUnchunkedStream = async function(readStream, writeStream, options={}) {
+const pipeUnchunkedStream = async function(readStream, writeStream) {
   try {
     while(true) {
       let chunkHead
@@ -111,7 +111,6 @@ const pipeUnchunkedStream = async function(readStream, writeStream, options={})
         writeStream.closeWrite()
         readStream.closeRead()
         return
-
       }
 
       readStream = await pipeChunk(readStream, writeStream, chunkSize)

Diff for: src/lib/head.js

@@ -1,6 +1,8 @@
 import { error } from 'quiver-core/util/error'
-import { pushbackStream } from 'quiver-core/stream-util'
 import { streamFilter } from 'quiver-core/component/constructor'
+import {
+  pushbackStream, streamToStreamable
+} from 'quiver-core/stream-util'
 
 export const extractStreamHead = async function(readStream, separator, options={}) {
   const { maxLength=-1 } = options

Diff for: src/lib/timeout.js

@@ -26,7 +26,6 @@ export const timeoutStream = (readStream, streamTimeout) => {
 export const timeoutStreamFilter = makeStreamConvertFilter()
   .addMiddleware(configMiddleware(
   config => {
-    const filterMode = config.get('filterMode', 'inout')
     const streamTimeout = config.get('streamTimeout', -1)
 
     if(!(streamTimeout > 0)) return

Diff for: src/test/buffer.js

@@ -3,8 +3,7 @@ import test from 'tape'
 import { asyncTest } from 'quiver-core/util/tape'
 
 import {
-  simpleHandler,
-  simpleHandlerLoader
+  simpleHandler
 } from 'quiver-core/component/constructor'
 
 import {
@@ -23,8 +22,7 @@ import {
 
 import {
   bufferConvertHandler,
-  bufferConvertFilter,
-  bufferStreamFilter
+  bufferConvertFilter
 } from '../lib'
 
 test('buffer convert test', assert => {

Diff for: src/test/chunked.js

@@ -2,14 +2,6 @@ import test from 'tape'
 
 import { asyncTest, rejected } from 'quiver-core/util/tape'
 
-import {
-  overrideConfig
-} from 'quiver-core/component/method'
-
-import {
-  loadHandler, createConfig, createArgs
-} from 'quiver-core/component/util'
-
 import {
   streamToText,
   buffersToStream

Diff for: src/test/compress.js

@@ -15,7 +15,6 @@ import {
 import { promisify } from 'quiver-core/util/promise'
 
 import {
-  simpleHandler,
   simpleHandlerBuilder
 } from 'quiver-core/component/constructor'
 
@@ -65,7 +64,7 @@ test('compress stream test', assert => {
       .then(streamToBuffer)
 
     assert.equal(Buffer.compare(
-      resultBuffer, compressed), 0)
+      cachedBuffer, compressed), 0)
 
     assert.end()
   })

Diff for: src/test/head.js

@@ -2,14 +2,6 @@ import test from 'tape'
 
 import { asyncTest } from 'quiver-core/util/tape'
 
-import {
-  overrideConfig
-} from 'quiver-core/component/method'
-
-import {
-  loadHandler, createConfig, createArgs
-} from 'quiver-core/component/util'
-
 import {
   streamToText,
   buffersToStream

Diff for: src/test/size.js

@@ -14,6 +14,8 @@ test('size windowed buffer test', assert => {
   assert::asyncTest('basic test', async function(assert) {
     const assertBuffer = async function(readStream, expected) {
       const { closed, data } = await readStream.read()
+      assert.notOk(closed)
+
       const result = data.toString()
       assert.equal(result, expected)
     }
@@ -37,7 +39,7 @@ test('size windowed buffer test', assert => {
     await assertBuffer(readStream, 'm dol')
     await assertBuffer(readStream, 'o')
 
-    const { closed, data } = await readStream.read()
+    const { closed } = await readStream.read()
     assert.ok(closed)
 
     assert.end()

Diff for: src/test/timeout.js

@@ -11,7 +11,7 @@ import {
 } from 'quiver-core/component/util'
 
 import {
-  simpleHandler, loadStreamHandler
+  simpleHandler
 } from 'quiver-core/component/constructor'
 
 import {
@@ -31,7 +31,7 @@ test('timeout stream test', assert => {
 
     writeStream.write('foo')
 
-    const { closed, data } = await readStream.read()
+    const { data } = await readStream.read()
     assert.equal(data, 'foo')
 
     await assert::rejected(readStream.read())