o rrrr[s zSearch.__init__TNcC"t|jj|j||d}|j|_|SzCreates a pipeline for the SEARCH module, that can be used for executing SEARCH commands, as well as classic core commands. )connection_poolresponse_callbacksrr)rrrJr=r>rrrprrrrrzSearch.pipeline)r<TN)r7r8r9r:r;rrrrrrrs  Crc@s(eZdZGdddejZdddZdS) AsyncSearchc@s.eZdZdZ      d ddZddZdS) zAsyncSearch.BatchIndexerrFr"Nc sf|jj|f|j||||||d||jd7_|jd7_|j|jkr1|IdHdSdSr#r+r-rrrr0s&   z%AsyncSearch.BatchIndexer.add_documentcs|jIdHd|_dS)r3Nrr4r rrrrs zAsyncSearch.BatchIndexer.commitr6)r7r8r9r:r0rrrrrr;s r;TNcCrHrI) AsyncPipelinerrJr=r>rLrrrrrNzAsyncSearch.pipelinerO)r7r8r9rr;rrrrrrPs+rPc@eZdZdZdS)rzPipeline for the module.Nr7r8r9r:rrrrrrc@rR)rQzAsyncPipeline for the module.NrSrrrrrQrTrQN) redis.clientr RedisPipelineasyncio.clientAsyncioPipelinecommandsrrrrr r r r r rrrPrQrrrrs 0n: