feat: fromCallback

Author: reconbot

lib/buffer.ts

@@ -1,5 +1,5 @@
 import { getIterator } from './get-iterator'
-import { defer, IDeferred } from './defer'
+import { defer, Deferred } from 'inside-out-async'
 import { AnyIterable, UnwrapAnyIterable } from './types'
 
 interface IValueObj<T> {
@@ -10,14 +10,14 @@ interface IValueObj<T> {
 function _buffer<T>(size: number, iterable: AsyncIterable<T>): AsyncIterableIterator<T> {
   const iterator = getIterator(iterable)
   const resultQueue: IValueObj<T>[] = []
-  const readQueue: IDeferred<IteratorResult<T>>[] = []
+  const readQueue: Deferred<IteratorResult<T>>[] = []
 
   let reading = false
   let ended = false
 
   function fulfillReadQueue() {
     while (readQueue.length > 0 && resultQueue.length > 0) {
-      const readDeferred = readQueue.shift() as IDeferred<IteratorResult<T>>
+      const readDeferred = readQueue.shift() as Deferred<IteratorResult<T>>
       const { error, value } = resultQueue.shift() as IValueObj<T>
       if (error) {
         readDeferred.reject(error)
@@ -26,7 +26,7 @@ function _buffer<T>(size: number, iterable: AsyncIterable<T>): AsyncIterableIter
       }
     }
     while (readQueue.length > 0 && ended) {
-      const { resolve } = readQueue.shift() as IDeferred<IteratorResult<T>>
+      const { resolve } = readQueue.shift() as Deferred<IteratorResult<T>>
       resolve({ done: true, value: undefined } as any)
     }
   }

lib/defer.ts

@@ -2,7 +2,7 @@ import { AnyIterable, FlatMapValue } from './types'
 import { flatten } from './flatten'
 import { filter } from './filter'
 import { getIterator } from './get-iterator'
-import { defer, IDeferred } from './defer'
+import { defer, Deferred } from 'inside-out-async'
 
 function _flatTransform<T, R>(
   concurrency: number,
@@ -12,7 +12,7 @@ function _flatTransform<T, R>(
   const iterator = getIterator(iterable)
 
   const resultQueue: R[] = []
-  const readQueue: IDeferred<IteratorResult<R>>[] = []
+  const readQueue: Deferred<IteratorResult<R>>[] = []
 
   let ended = false
   let reading = false
@@ -21,12 +21,12 @@ function _flatTransform<T, R>(
 
   function fulfillReadQueue() {
     while (readQueue.length > 0 && resultQueue.length > 0) {
-      const { resolve } = readQueue.shift() as IDeferred<IteratorResult<R>>
+      const { resolve } = readQueue.shift() as Deferred<IteratorResult<R>>
       const value = resultQueue.shift() as R
       resolve({ done: false, value } as any)
     }
     while (readQueue.length > 0 && inflightCount === 0 && ended) {
-      const { resolve, reject } = readQueue.shift() as IDeferred<IteratorResult<R>>
+      const { resolve, reject } = readQueue.shift() as Deferred<IteratorResult<R>>
       if (lastError) {
         reject(lastError)
         lastError = null

lib/flat-transform.ts

@@ -1,6 +1,6 @@
 import { AnyIterable } from './types'
 import { getIterator } from './get-iterator'
-import { defer, IDeferred } from './defer'
+import { defer, Deferred } from 'inside-out-async'
 
 function _transform<T, R>(
   concurrency: number,
@@ -10,7 +10,7 @@ function _transform<T, R>(
   const iterator = getIterator(iterable)
 
   const resultQueue: R[] = []
-  const readQueue: IDeferred<IteratorResult<R>>[] = []
+  const readQueue: Deferred<IteratorResult<R>>[] = []
 
   let ended = false
   let reading = false
@@ -19,12 +19,12 @@ function _transform<T, R>(
 
   function fulfillReadQueue() {
     while (readQueue.length > 0 && resultQueue.length > 0) {
-      const { resolve } = readQueue.shift() as IDeferred<IteratorResult<R>>
+      const { resolve } = readQueue.shift() as Deferred<IteratorResult<R>>
       const value = resultQueue.shift() as R
       resolve({ done: false, value } as any)
     }
     while (readQueue.length > 0 && inflightCount === 0 && ended) {
-      const { resolve, reject } = readQueue.shift() as IDeferred<IteratorResult<R>>
+      const { resolve, reject } = readQueue.shift() as Deferred<IteratorResult<R>>
       if (lastError) {
         reject(lastError)
         lastError = null

lib/transform.ts

@@ -2,7 +2,7 @@ import { assert } from 'chai'
 import { writeToStream } from './'
 import { PassThrough, Transform, Writable } from 'stream'
 import { promiseImmediate } from './util-test'
-import { defer } from './defer'
+import { defer } from 'inside-out-async'
 
 describe('writeToStream', () => {
   it('writes values to a stream', async () => {