daurnimator / lredis Goto Github PK

cq:wrap(function()
  client:multi()
  cqueues.sleep(5)
  client:call('get', 'test')
  client:exec()
end)

cq:wrap(function()
  cqueues.sleep(2)
  client:ping()
end)

cq:loop()

cq:wrap(function()
  local t = client:multi()
  cqueues.sleep(5)
  t:call('get', 'test')
  t:exec()
end)

cq:wrap(function()
  cqueues.sleep(2)
  client:ping() -- this is now blocked until the exec() completes.
end)

cq:loop()

--- Stream class do protocol decode/encode

-- all handlers gets SELF as first argument
stream = RedisStream.new(SELF)
-- do write here
:on_command(function(self, data)
  -- write `data` to output stream
  -- call 
end)
-- handle async messages here
:on_message(function(self, channel, data)
end)
-- internal or protocol error
:on_halt(function(self, err)
end)

-- read data from input stream
chunk = io.read

-- append data to stream and execute 
stream:append(chunk):execute()

-- any command 
stream:command(<COMMAND HERE>, function(self, err, result)
...
end)

--- Commander class encode/decode arguments/reuslts of command

command = RedisCommander.new(stream)
command:ping(function(self, err, ok) end)