Hands-On Software Engineering with Golang

Synchronous pipelines

A synchronous pipeline essentially processes one payload at a time. We could implement such a pipeline by creating a for loop that does the following:

• Dequeues the next payload from the input source or exits the loop if no more payloads are available
• Iterates the list of pipeline stages and invokes the Processor instance for each stage
• Enqueues the resulting payload to the output source

Synchronous pipelines are great for workloads where payloads must always be processed in first-in-first-out (FIFO) fashion, a quite common case for event-driven architectures which, most of the time, operate under the assumption that events are always processed in a specific order.

As an example, let's say that we are trying to construct ...