class Redis::Pipeline::Multi

def commands
  [[:multi]] + super + [[:exec]]
end

def finish(replies)
  return if replies.last.nil? # The transaction failed because of WATCH.
  if replies.last.size < futures.size - 2
    # Some command wasn't recognized by Redis.
    raise replies.detect { |r| r.kind_of?(::Exception) }
  end
  super(replies.last)
end