Don't need resource pool anymore.

spec/resource-pool-spec.js

@@ -1,66 +0,0 @@
-/** @babel */
-
-import ResourcePool from '../src/resource-pool'
-
-import {it} from './async-spec-helpers'
-
-describe('ResourcePool', () => {
-  let queue
-
-  beforeEach(() => {
-    queue = new ResourcePool([{}])
-  })
-
-  describe('.enqueue', () => {
-    it('calls the enqueued function', async () => {
-      let called = false
-      await queue.enqueue(() => {
-        called = true
-        return Promise.resolve()
-      })
-      expect(called).toBe(true)
-    })
-
-    it('forwards values from the inner promise', async () => {
-      const result = await queue.enqueue(() => Promise.resolve(42))
-      expect(result).toBe(42)
-    })
-
-    it('forwards errors from the inner promise', async () => {
-      let threw = false
-      try {
-        await queue.enqueue(() => Promise.reject(new Error('down with the sickness')))
-      } catch (e) {
-        threw = true
-      }
-      expect(threw).toBe(true)
-    })
-
-    it('continues to dequeue work after a promise has been rejected', async () => {
-      try {
-        await queue.enqueue(() => Promise.reject(new Error('down with the sickness')))
-      } catch (e) {}
-
-      const result = await queue.enqueue(() => Promise.resolve(42))
-      expect(result).toBe(42)
-    })
-
-    it('queues up work', async () => {
-      let resolve = null
-      queue.enqueue(() => {
-        return new Promise((resolve_, reject) => {
-          resolve = resolve_
-        })
-      })
-
-      expect(queue.getQueueDepth()).toBe(0)
-
-      queue.enqueue(() => new Promise((resolve, reject) => {}))
-
-      expect(queue.getQueueDepth()).toBe(1)
-      resolve()
-
-      waitsFor(() => queue.getQueueDepth() === 0)
-    })
-  })
-})

src/resource-pool.js

@@ -1,57 +0,0 @@
-/** @babel */
-
-// Manages a pool of some resource.
-export default class ResourcePool {
-  constructor (pool) {
-    this.pool = pool
-
-    this.queue = []
-  }
-
-  // Enqueue the given function. The function will be given an object from the
-  // pool. The function must return a {Promise}.
-  enqueue (fn) {
-    let resolve = null
-    let reject = null
-    const wrapperPromise = new Promise((resolve_, reject_) => {
-      resolve = resolve_
-      reject = reject_
-    })
-
-    this.queue.push(this.wrapFunction(fn, resolve, reject))
-
-    this.dequeueIfAble()
-
-    return wrapperPromise
-  }
-
-  wrapFunction (fn, resolve, reject) {
-    return (resource) => {
-      const promise = fn(resource)
-      promise
-        .then(result => {
-          resolve(result)
-          this.taskDidComplete(resource)
-        }, error => {
-          reject(error)
-          this.taskDidComplete(resource)
-        })
-    }
-  }
-
-  taskDidComplete (resource) {
-    this.pool.push(resource)
-
-    this.dequeueIfAble()
-  }
-
-  dequeueIfAble () {
-    if (!this.pool.length || !this.queue.length) return
-
-    const fn = this.queue.shift()
-    const resource = this.pool.shift()
-    fn(resource)
-  }
-
-  getQueueDepth () { return this.queue.length }
-}