@@ -31,14 +31,16 @@ class AsyncTransport(Transport):
3131 ]
3232
3333 def __init__ (self , loop , cache = None , timeout = 300 , operation_timeout = None ,
34- session = None ):
34+ session = None , verify_ssl = True , proxy = None ):
3535
3636 self .loop = loop if loop else asyncio .get_event_loop ()
3737 self .cache = cache
3838 self .load_timeout = timeout
3939 self .operation_timeout = operation_timeout
4040 self .logger = logging .getLogger (__name__ )
4141
42+ self .verify_ssl = verify_ssl
43+ self .proxy = proxy
4244 self .session = session or aiohttp .ClientSession (loop = self .loop )
4345 self ._close_session = session is None
4446 self .session ._default_headers ['User-Agent' ] = (
@@ -81,7 +83,8 @@ async def post(self, address, message, headers):
8183 self .logger .debug ("HTTP Post to %s:\n %s" , address , message )
8284 with aio_timeout (self .operation_timeout ):
8385 response = await self .session .post (
84- address , data = message , headers = headers )
86+ address , data = message , headers = headers ,
87+ verify_ssl = self .verify_ssl , proxy = self .proxy )
8588 self .logger .debug (
8689 "HTTP Response from %s (status: %d):\n %s" ,
8790 address , response .status , await response .read ())
@@ -95,7 +98,8 @@ async def post_xml(self, address, envelope, headers):
9598 async def get (self , address , params , headers ):
9699 with aio_timeout (self .operation_timeout ):
97100 response = await self .session .get (
98- address , params = params , headers = headers )
101+ address , params = params , headers = headers ,
102+ verify_ssl = self .verify_ssl , proxy = self .proxy )
99103
100104 return await self .new_response (response )
101105
0 commit comments