wrapping Bacon.js Streams with Opal

bacon.rb

Bacon = Native `Bacon`


class ProxyStream
  
  def initialize(wrapped)
    @wrapped = wrapped
  end
  
  def method_missing(method,*args) 
    Bacon.fromCallback do |cb|
      @wrapped.send(method,*args) do |response|
        cb.call  response
      end
    end
  end
  
end

Rest = ProxyStream.new HTTP



ip = Rest.get('http://ip.jsontest.com/?callback=?',dataType:'json').map { |response| response.json[:ip]}
time = Rest.get('http://date.jsontest.com/',dataType:'json').map {|response| response.json[:time] }

Bacon.combineTemplate(ip:ip,time:time).onValue do |response| 
  response = Native(response) 
  p response.ip
  p response.time
end

Bacon.Observable.prototype.onValue = function(f) { old.apply(this,[function(value) { f("".$Native(value)) }]) }