p-transform

p-transform

Promised out of order transform.

Usage

Builds a out-of-order Duplex using a p-queue parallel queue. transform implementation must be sync or return a promise. Callback is not supported.

Promisified pipeline and transform shortcut are provided for convenience.

import { OutOfOrder, transform, pipeline, passthrough, filter } from 'p-transform';

await pipeline(
  new OutOfOrder(
    { transform: async file => file },
    { concurrency: 7 },
  ).duplex(() => console.log('done')),
  passthrough(async file => {}, () => console.log('done')),
  filter(async file => true, () => console.log('done')),
  transform(async file => file, () => console.log('done')),
)

Debug

Use DEBUG=p-transform:* environment variable.

License

Apache-2.0

API

Classes

OutOfOrder

Constants

pipeline

Promisified pipeline

Functions

transform(transform, end)

Shortcut to create a OutOfOrder with transform and end callback

passthrough(spy, end)

Shortcut to create a passthrough OutOfOrder with spy and end callback

filter(filter, end)

Shortcut to create a filter OutOfOrder with filter and end callback

OutOfOrder

Kind: global class

• OutOfOrder
  • new OutOfOrder(transform[, options])
  • .duplex(endCallback) ⇒ Duplex

new OutOfOrder(transform[, queueOptions])

OutOfOrder

Param	Type	Description
[transform]	function	Transform.
[queueOptions]	Object	Options forwarded to PQueue instance.

outOfOrder.duplex(end) ⇒ Duplex

Build Duplex.

Kind: instance method of OutOfOrder Returns: Duplex

Param	Type
end	function

pipeline

Promisified pipeline

Kind: global constant

transform(transform, end)

Shortcut to create a OutOfOrder with transform and end callback.

Kind: global function

Param	Type
transform	function
end	function

passthrough(spy, end)

Shortcut to create a passthrough OutOfOrder with spy and end callback.

Kind: global function

Param	Type
spy	function
end	function

filter(filter, end)

Shortcut to create a filter OutOfOrder with filter and end callback.

Kind: global function

Param	Type
filter	function
end	function