Class: Pull::Log

Inherits:
Object
  • Object
show all
Defined in:
lib/pull/sink/log.rb

Constant Summary collapse

DEFAULT_DONE_CALLBACK = 
-> () {
  puts "DONE"
}

Instance Method Summary collapse

Instance Method Details

#call(read, done = DEFAULT_DONE_CALLBACK) ⇒ Object

Raises:

  • (TypeError) 


9
10
11
12
13
14
 
# File 'lib/pull/sink/log.rb', line 9

def call(read, done = DEFAULT_DONE_CALLBACK)
  raise TypeError unless read.respond_to?(:call)
  Pull::Drain.new do |value|
    puts value
  end.(read)
end