public protocol ProducerType: class {

    associatedtype OutputType

    var consumer: (OutputType -> Void)? { get set }
}


public protocol ConsumerType: class {

    associatedtype InputType

    func consume(_: InputType)
}

public protocol TransformerType: ConsumerType, ConsumableType {

}