kill em / redis / bloomfilter

gistfile1.txt

require 'redis'
require 'redis/connection/synchrony'
require "em-synchrony/fiber_iterator"
require 'bloomfilter-rb'
max = 10_000
EM.synchrony do
  LBF = BloomFilter::Redis.new(:size => max, :hashes => 2, :seed => 1,:namespace => "test")
  process_queue = lambda do
   Fiber.new{
   
      array = []
      max.times.each{ array << rand(max)}
      EM::Synchrony::FiberIterator.new(array).each do |x|
        in_bf =  LBF.include?(x)
        puts "#{x} in bm #{in_bf}"
        LBF.insert(x) unless in_bf
      end
      array = nil 
     EM.next_tick { process_queue.call  }      
    }.resume
  end
  EM.add_periodic_timer(1){ process_queue.call }
end