mirror of
https://github.com/Rapptz/discord.py.git
synced 2025-06-07 20:28:38 +00:00
Explicitly close responses that don't get read.
This commit is contained in:
parent
9deb7796a5
commit
9e36047ffb
@ -633,6 +633,7 @@ class Client:
|
|||||||
response = yield from self.session.post(url, headers=self.headers)
|
response = yield from self.session.post(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='POST', response=response))
|
log.debug(request_logging_format.format(method='POST', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def send_file(self, destination, fp, filename=None):
|
def send_file(self, destination, fp, filename=None):
|
||||||
@ -734,6 +735,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def edit_message(self, message, new_content, *, mentions=True):
|
def edit_message(self, message, new_content, *, mentions=True):
|
||||||
@ -873,6 +875,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def ban(self, member):
|
def ban(self, member):
|
||||||
@ -903,6 +906,7 @@ class Client:
|
|||||||
response = yield from self.session.put(url, headers=self.headers)
|
response = yield from self.session.put(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='PUT', response=response))
|
log.debug(request_logging_format.format(method='PUT', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def unban(self, member):
|
def unban(self, member):
|
||||||
@ -933,6 +937,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def server_voice_state(self, member, *, mute=False, deafen=False):
|
def server_voice_state(self, member, *, mute=False, deafen=False):
|
||||||
@ -972,6 +977,7 @@ class Client:
|
|||||||
response = yield from self.session.patch(url, headers=self.headers, data=utils.to_json(payload))
|
response = yield from self.session.patch(url, headers=self.headers, data=utils.to_json(payload))
|
||||||
log.debug(request_logging_format.format(method='PATCH', response=response))
|
log.debug(request_logging_format.format(method='PATCH', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def edit_profile(self, password, **fields):
|
def edit_profile(self, password, **fields):
|
||||||
@ -1214,6 +1220,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
# Server management
|
# Server management
|
||||||
|
|
||||||
@ -1242,6 +1249,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def create_server(self, name, region=None, icon=None):
|
def create_server(self, name, region=None, icon=None):
|
||||||
@ -1349,6 +1357,7 @@ class Client:
|
|||||||
r = yield from self.session.patch(url, headers=self.headers, data=utils.to_json(payload))
|
r = yield from self.session.patch(url, headers=self.headers, data=utils.to_json(payload))
|
||||||
log.debug(request_logging_format.format(method='PATCH', response=r))
|
log.debug(request_logging_format.format(method='PATCH', response=r))
|
||||||
yield from utils._verify_successful_response(r)
|
yield from utils._verify_successful_response(r)
|
||||||
|
yield from r.release()
|
||||||
|
|
||||||
# Invite management
|
# Invite management
|
||||||
|
|
||||||
@ -1483,6 +1492,7 @@ class Client:
|
|||||||
response = yield from self.session.post(url, headers=self.headers)
|
response = yield from self.session.post(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='POST', response=response))
|
log.debug(request_logging_format.format(method='POST', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def delete_invite(self, invite):
|
def delete_invite(self, invite):
|
||||||
@ -1513,6 +1523,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
# Role management
|
# Role management
|
||||||
|
|
||||||
@ -1605,6 +1616,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def add_roles(self, member, *roles):
|
def add_roles(self, member, *roles):
|
||||||
@ -1702,6 +1714,7 @@ class Client:
|
|||||||
r = yield from self.session.patch(url, headers=self.headers, data=utils.to_json(payload))
|
r = yield from self.session.patch(url, headers=self.headers, data=utils.to_json(payload))
|
||||||
log.debug(request_logging_format.format(method='PATCH', response=r))
|
log.debug(request_logging_format.format(method='PATCH', response=r))
|
||||||
yield from utils._verify_successful_response(r)
|
yield from utils._verify_successful_response(r)
|
||||||
|
yield from r.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def create_role(self, server, **fields):
|
def create_role(self, server, **fields):
|
||||||
@ -1807,6 +1820,7 @@ class Client:
|
|||||||
r = yield from self.session.put(url, data=utils.to_json(payload), headers=self.headers)
|
r = yield from self.session.put(url, data=utils.to_json(payload), headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='PUT', response=r))
|
log.debug(request_logging_format.format(method='PUT', response=r))
|
||||||
yield from utils._verify_successful_response(r)
|
yield from utils._verify_successful_response(r)
|
||||||
|
yield from r.release()
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def delete_channel_permissions(self, channel, target):
|
def delete_channel_permissions(self, channel, target):
|
||||||
@ -1840,6 +1854,7 @@ class Client:
|
|||||||
response = yield from self.session.delete(url, headers=self.headers)
|
response = yield from self.session.delete(url, headers=self.headers)
|
||||||
log.debug(request_logging_format.format(method='DELETE', response=response))
|
log.debug(request_logging_format.format(method='DELETE', response=response))
|
||||||
yield from utils._verify_successful_response(response)
|
yield from utils._verify_successful_response(response)
|
||||||
|
yield from response.release()
|
||||||
|
|
||||||
|
|
||||||
# Voice management
|
# Voice management
|
||||||
|
Loading…
x
Reference in New Issue
Block a user