Pipeline Composition

Composition operations in the PIPELINE pillar.

compose

const processor = pipeline.compose([
  data => pipeline.validate(data, schema),
  data => pipeline.filter(data, item => item.active),
  data => pipeline.map(data, item => transform(item))
])

chain

const result = pipeline.chain(data, [
  data => processStep1(data),
  data => processStep2(data),
  data => processStep3(data)
])

Next Steps

• PIPELINE Pillar
• Data Flow Operations
• Examples