class J8::Consumer

Public Instance Methods

accept(o) click to toggle source
# File lib/j8/consumer.rb, line 7
def accept(o)
  @callable.call(o)
end
then(after = nil, &block) click to toggle source
# File lib/j8/consumer.rb, line 11
def then(after = nil, &block)
  callable = from_callable(after, block)

  J8::Consumer.new(
    lambda do |o|
      accept(o)
      callable.accept(o)
    end
  )
end