#EnrichStream

A stream that enables asynchronous enrichment of data with concurrency control while preserving FIFO ordering.

##Implementation

• Enrichment is asynchronous.
• Concurrency is controlled via async.queue.
• Stream writes are buffered until enrichment has completed.

##Use Cases Given that enrichment likely takes time which requires buffering the current best use cases are where enrichment is expected to be relatively fast. Use a control stream or other mechanism could be used to tune performance.

##Running Tests Run node test to send a stream of values for enrichment that are checked for being output in order.