Transaction::subscribe fails if not all steps specifies publish: true

[kwando]

noop = -> input { input }
container = {
  validate: noop,
  persist: noop
}

class Responder
  def self.validate_failure(input, error)
    # handle error here
  end
end

transaction = Transflow(container: container){
  step(:validate, publish: true)
  step(:persist)
}

transaction.subscribe(Responder)
transaction[hello: 'world']

/Users/kwando/Desktop/transflow/vendor/bundle/gems/transflow-0.3.0/lib/transflow/transaction.rb:78:in `block in subscribe': undefined method `subscribe' for #<Proc:[email protected]:3 (lambda)> (NoMethodError)
    from /Users/kwando/Desktop/transflow/vendor/bundle/gems/transflow-0.3.0/lib/transflow/transaction.rb:78:in `each'
    from /Users/kwando/Desktop/transflow/vendor/bundle/gems/transflow-0.3.0/lib/transflow/transaction.rb:78:in `subscribe'
    from test.rb:20:in `<main>'