fix: more compatibility with redis client (#86)

Author: supercaracal

lib/redis_client/cluster.rb

@@ -17,16 +17,16 @@ def inspect
       "#<#{self.class.name} #{@router.node.node_keys.join(', ')}>"
     end
 
-    def call(*command, **kwargs)
-      @router.send_command(:call, *command, **kwargs)
+    def call(*command, **kwargs, &block)
+      @router.send_command(:call, *command, **kwargs, &block)
     end
 
-    def call_once(*command, **kwargs)
-      @router.send_command(:call_once, *command, **kwargs)
+    def call_once(*command, **kwargs, &block)
+      @router.send_command(:call_once, *command, **kwargs, &block)
     end
 
-    def blocking_call(timeout, *command, **kwargs)
-      @router.send_command(:blocking_call, timeout, *command, **kwargs)
+    def blocking_call(timeout, *command, **kwargs, &block)
+      @router.send_command(:blocking_call, timeout, *command, **kwargs, &block)
     end
 
     def scan(*args, **kwargs, &block)
@@ -74,10 +74,10 @@ def close
 
     private
 
-    def method_missing(name, *args, **kwargs)
+    def method_missing(name, *args, **kwargs, &block)
       if @router.command_exists?(name)
         args.unshift(name)
-        return @router.send_command(:call, *args)
+        return @router.send_command(:call, *args, **kwargs, &block)
       end
 
       super

test/redis_client/test_cluster.rb

@@ -23,20 +23,32 @@ def test_inspect
 
       def test_call
         assert_raises(ArgumentError) { @client.call }
+
         (0..9).each do |i|
           assert_equal('OK', @client.call('SET', "key#{i}", i), "Case: SET: key#{i}")
           wait_for_replication
           assert_equal(i.to_s, @client.call('GET', "key#{i}"), "Case: GET: key#{i}")
         end
+
+        assert(@client.call('PING') { |r| r == 'PONG' })
+
+        assert_equal(2, @client.call('HSET', 'hash', { foo: 1, bar: 2 }))
+        assert_equal(%w[1 2], @client.call('HMGET', 'hash', %w[foo bar]))
       end
 
       def test_call_once
         assert_raises(ArgumentError) { @client.call_once }
+
         (0..9).each do |i|
           assert_equal('OK', @client.call_once('SET', "key#{i}", i), "Case: SET: key#{i}")
           wait_for_replication
           assert_equal(i.to_s, @client.call_once('GET', "key#{i}"), "Case: GET: key#{i}")
         end
+
+        assert(@client.call_once('PING') { |r| r == 'PONG' })
+
+        assert_equal(2, @client.call_once('HSET', 'hash', { foo: 1, bar: 2 }))
+        assert_equal(%w[1 2], @client.call_once('HMGET', 'hash', %w[foo bar]))
       end
 
       def test_blocking_call