A suite of jobs piped together.

Pipeline.swift

struct Pipeline<Input, Output>: Job, CustomStringConvertible {
    let description: String
    private let _getOutput: (Input) throws -> Output
    
  init(description: String, _ getOutput: @escaping (Input) throws -> Output) {
        self.description = description
        self._getOutput = getOutput
    }
}

// MARK: Job
extension Pipeline {
    func work(input: Input) throws -> Output {
        return try _getOutput(input)
    }
}