curl.setopt(pycurl.URL, url.encode('utf-8'))
curl.setopt(pycurl.HTTPHEADER, [
'{}: {}'.format(k,v) for k,v in self.get_headers.iteritems()])
- curl.setopt(pycurl.WRITEDATA, response_body)
+ curl.setopt(pycurl.WRITEFUNCTION, response_body.write)
curl.setopt(pycurl.HEADERFUNCTION, self._headerfunction)
self._setcurltimeouts(curl, timeout)
try:
curl.setopt(pycurl.CUSTOMREQUEST, 'PUT')
curl.setopt(pycurl.HTTPHEADER, [
'{}: {}'.format(k,v) for k,v in self.put_headers.iteritems()])
- curl.setopt(pycurl.WRITEDATA, response_body)
+ curl.setopt(pycurl.WRITEFUNCTION, response_body.write)
curl.setopt(pycurl.HEADERFUNCTION, self._headerfunction)
self._setcurltimeouts(curl, timeout)
try:
def setopt(self, opt, val):
self._opt[str(opt)] = val
- if opt == pycurl.WRITEDATA:
+ if opt == pycurl.WRITEFUNCTION:
self._writer = val
elif opt == pycurl.HEADERFUNCTION:
self._headerfunction = val
self._headerfunction("HTTP/1.1 {} Status".format(self._resp_code))
for k, v in self._resp_headers.iteritems():
self._headerfunction(k + ': ' + str(v))
- self._writer.write(self._resp_body)
+ self._writer(self._resp_body)
def close(self):
pass