Synchronize redis operations with task-aware latch.

Author: marshall-lee

lib/celluloid/redis.rb

@@ -1,3 +1,19 @@
 require "redis"
 
 require "celluloid/redis/version"
+require "celluloid/io"
+
+module Celluloid
+  class Redis < ::Redis
+    VERSION = CelluloidRedis::VERSION
+
+    def synchronize
+      if @options[:driver] == :celluloid
+        @latch ||= Celluloid::IO::Stream::Latch.new
+        @latch.synchronize { yield @client }
+      else
+        super(&proc)
+      end
+    end
+  end
+end