64 |
64 |
65 def open(self, server): |
65 def open(self, server): |
66 ip, port = server.split(':') |
66 ip, port = server.split(':') |
67 self.connection = ip, int(port) |
67 self.connection = ip, int(port) |
68 |
68 |
69 def get(self, key, default=None): |
69 async def get(self, key, default=None): |
70 connection = yield from aioredis.create_connection(self.connection) |
70 connection = await aioredis.create_connection(self.connection) |
71 yield from connection.execute('get', key) |
71 value = await connection.execute('get', key) |
|
72 connection.close() |
|
73 await connection.wait_closed() |
|
74 return value |
72 |
75 |
73 def set(self, key, value): |
76 async def set(self, key, value): |
74 connection = yield from aioredis.create_connection(self.connection) |
77 connection = await aioredis.create_connection(self.connection) |
75 yield from connection.execute('set', key, value) |
78 await connection.execute('set', key, value) |
|
79 connection.close() |
|
80 await connection.wait_closed() |