(r *Request)
| 237 | } |
| 238 | |
| 239 | func (s *Session) handleResponse(r *Request) (*redis.Resp, error) { |
| 240 | r.Batch.Wait() |
| 241 | if r.Coalesce != nil { |
| 242 | if err := r.Coalesce(); err != nil { |
| 243 | return nil, err |
| 244 | } |
| 245 | } |
| 246 | if err := r.Err; err != nil { |
| 247 | return nil, err |
| 248 | } else if r.Resp == nil { |
| 249 | return nil, ErrRespIsRequired |
| 250 | } |
| 251 | return r.Resp, nil |
| 252 | } |
| 253 | |
| 254 | func (s *Session) handleRequest(r *Request, d *Router) error { |
| 255 | opstr, flag, err := getOpInfo(r.Multi) |