| 63 | } |
| 64 | |
| 65 | void redis_pipeline_message::push(const redis_result* result) { |
| 66 | // One reference for the message itself, and the other one was added |
| 67 | // in redis_client_pipeline::exec(). |
| 68 | |
| 69 | result_ = result; |
| 70 | box_->push(this, false); |
| 71 | |
| 72 | // Just decrease the reference added in redis_client_pipeline::exec(). |
| 73 | unrefer(); |
| 74 | } |
| 75 | |
| 76 | const redis_result* redis_pipeline_message::wait() const { |
| 77 | box_->pop(-1, NULL); |
no test coverage detected