Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(13)  |  Call(12)  |  Derive(0)  |  Import(1)
Hiredis protocol reader

src/s/l/slapos.cookbook-0.87/slapos/recipe/redis/MyRedis2410.py   slapos.cookbook(Download)
    def on_connect(self, connection):
        self._sock = connection._sock
        self._reader = hiredis.Reader(
            protocolError=InvalidResponse,
            replyError=ResponseError)

src/s/l/slapos-HEAD/slapos/recipe/redis/MyRedis2410.py   slapos(Download)
    def on_connect(self, connection):
        self._sock = connection._sock
        self._reader = hiredis.Reader(
            protocolError=InvalidResponse,
            replyError=ResponseError)

src/t/x/txredis-2.3/txredis/client.py   txredis(Download)
    def __init__(self, db=None, password=None, charset='utf8',
                 errors='strict'):
        super(HiRedisClient, self).__init__(db, password, charset, errors)
        self._reader = hiredis.Reader(protocolError=exceptions.InvalidData,
                                      replyError=exceptions.ResponseError)

src/t/x/txRedis-HEAD/txredis/client.py   txRedis(Download)
    def __init__(self, db=None, password=None, charset='utf8',
                 errors='strict'):
        super(HiRedisClient, self).__init__(db, password, charset, errors)
        self._reader = hiredis.Reader(protocolError=exceptions.InvalidData,
                                      replyError=exceptions.ResponseError)

src/a/k/akane-HEAD/akane/connection.py   akane(Download)
    def __init__(self, host='localhost', port=6379, ioloop=None):
        self.host = host
        self.port = port
        self._ioloop = ioloop or IOLoop.instance()
        self._parser = hiredis.Reader(encoding="utf-8")

src/h/i/hiredis-0.1.3/hiredis/__init__.py   hiredis(Download)
from .hiredis import Reader, HiredisError, ProtocolError, ReplyError
from .version import __version__
 
__all__ = [
  "Reader", "HiredisError", "ProtocolError", "ReplyError",

src/w/e/WeiboSpider-HEAD/lib/redis/connection.py   WeiboSpider(Download)
        if connection.decode_responses:
            kwargs['encoding'] = connection.encoding
        self._reader = hiredis.Reader(**kwargs)
 
    def on_disconnect(self):

src/t/o/toredis-0.1.2/toredis/client.py   toredis(Download)
    def _reset(self):
        self.reader = hiredis.Reader()
        self._sub_callback = None
 

src/t/o/toredis-mease-0.1.2/toredis/client.py   toredis-mease(Download)
    def _reset(self):
        self.reader = hiredis.Reader()
        self._sub_callback = None
 
    def pipeline(self):

src/r/e/redis-2.9.1/redis/connection.py   redis(Download)
        if connection.decode_responses:
            kwargs['encoding'] = connection.encoding
        self._reader = hiredis.Reader(**kwargs)
 
    def on_disconnect(self):

  1 | 2  Next