Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

reuse lbrycrd connector

Browse source
This commit is contained in:
Jack Robison 2019-06-28 13:47:27 -04:00
parent 66122a45ed
commit 8b0d96acba
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
torba/torba/server/daemon.py
View file

@ -55,6 +55,7 @@ class Daemon:
self.max_retry = max_retry self.max_retry = max_retry
self._height = None self._height = None
self.available_rpcs = {} self.available_rpcs = {}
self.connector = aiohttp.TCPConnector()
def set_url(self, url): def set_url(self, url):
"""Set the URLS to the given list, and switch to the first one.""" """Set the URLS to the given list, and switch to the first one."""
@ -89,7 +90,7 @@ class Daemon:
def client_session(self): def client_session(self):
"""An aiohttp client session.""" """An aiohttp client session."""
return aiohttp.ClientSession() return aiohttp.ClientSession(connector=self.connector, connector_owner=False)
async def _send_data(self, data): async def _send_data(self, data):
async with self.workqueue_semaphore: async with self.workqueue_semaphore: