in plugin/src/main/groovy/grails/plugins/redis/RedisService.groovy [45:51]
def withPipeline(Closure closure, Boolean returnAll = false) {
withRedis { Jedis redis ->
Pipeline pipeline = redis.pipelined()
closure(pipeline)
returnAll ? pipeline.syncAndReturnAll() : pipeline.sync()
}
}