Contents

#!/usr/bin/env ruby
require "rubygems"
$:.unshift File.expand_path '../lib', File.dirname(__FILE__)
require 'em-rocketio-linda-client'

url = ARGV.empty? ? "http://linda.shokai.org" : ARGV.shift

EM::run do
  client = EM::RocketIO::Linda::Client.new url
  ts = client.tuplespace["test_spae"]

  client.io.on :connect do
    puts "connect #{client.io.type} (#{client.io.session})"

    ts.watch [1,2] do |tuple, info|
      p tuple
    end

    EM::add_periodic_timer 1 do
      ts.write [1,2, Time.now]

      ts.list [1,2] do |list|
        puts "#{list.size} tuples in exists"
      end
    end
  end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
em-rocketio-linda-client-1.1.1	sample/sample.rb
em-rocketio-linda-client-1.1.0	sample/sample.rb