Problem

At Present, the functionalities of running a pipeline is encapsulated inside Process Worker. While this provides encapsulation, it does not provide a way for a given thread such as in the case of Zero buffer to execute processors and publish to sinks in a synchronous way without having an instance of Process Worker itself which contains additional responsibilities such as shutting down process for pipeline.

Describe the solution you'd like

Implement a Pipeline Runner by moving the functionalities of to reading from buffer, executing processors and publishing to sinks from process worker to a Pipeline runner class, which can be used by process worker and other threads.

Additional context

Zero Buffer