yankov

# refactored version from http://redis.io/topics/mass-insert

def gen_redis_proto(*cmd)
  cmd.inject("*#{cmd.length}\r\n") {|acc, arg|
    acc << "$#{arg.length}\r\n#{arg}\r\n"
  }
end

yankov

# is there a good pattern for this routine?

EM.synchrony do
  
  size = keys.count
  counter = 0
  
  # check if each iteration was completed
  EM::add_periodic_timer( 2 ) do 
    next unless counter == size

yankov

require 'em-synchrony'
require 'redis'
require 'redis/distributed'
require 'digest'
require 'redis/connection/synchrony'

EM.synchrony do
 
# this one fast
 redis_hosts = ["redis://localhost:6379/1", "redis://localhost:6378/1"]

yankov

var future = function(d) { 
  var obj = {}; 
  obj.val = 0; 

  setTimeout(function(){ obj.val=d;}, 5000); 

  return obj;  
}

var result = future(4); 

yankov

# do gem install web-socket-ruby first

require 'web_socket'
require 'json'

client = WebSocket.new("ws://localhost:8080/eventbus/websocket")

message = {:name => "tim", :age => 29}
envelope = {:type => "send",
            :address => "some-address",

yankov

require 'vertx'

server = Vertx::HttpServer.new;
sockJSServer = Vertx::SockJSServer.new(server)
sockJSServer.bridge({'prefix' => '/eventbus'}, [] )
server.listen(8080)

yankov

<script type='text/javascript' src='http://cdn.sockjs.org/sockjs-0.1.min.js'></script>
<script type='text/javascript' src='vertxbus.js'></script>

<script type="text/javascript">

var eb = null;

window.onload = function() {

    eb = new vertx.EventBus("http://localhost:8080/eventbus");

yankov

require 'redis'
require 'face'

# fb user_id of the user that needs to be find on match.com
FB_UID = '11111@facebook.com'

# show all profiles whith the given confidence of recognition
ACCURACY = 30

redis = Redis.new

yankov

require 'nokogiri'
require 'eventmachine'
require 'em-http-request'
require 'em-redis'

PAGES = 140

EM.run {

  @redis = EM::Protocols::Redis.connect

yankov

require 'rubygems'  
require 'open-uri'  

response = open(YOUR_URL_OF_REUEST)  

p response.read