File tree 2 files changed +6
-6
lines changed
sdk/servicebus/azure-servicebus/azure/servicebus
2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change 2
2
# Copyright (c) Microsoft Corporation. All rights reserved.
3
3
# Licensed under the MIT License. See License.txt in the project root for license information.
4
4
# --------------------------------------------------------------------------------------------
5
- from typing import Any , TYPE_CHECKING
5
+ from typing import Any , List , TYPE_CHECKING
6
6
7
7
import uamqp
8
8
9
- from ._base_handler import _parse_conn_str , ServiceBusSharedKeyCredential
9
+ from ._base_handler import _parse_conn_str , ServiceBusSharedKeyCredential , BaseHandler
10
10
from ._servicebus_sender import ServiceBusSender
11
11
from ._servicebus_receiver import ServiceBusReceiver
12
12
from ._servicebus_session_receiver import ServiceBusSessionReceiver
@@ -69,7 +69,7 @@ def __init__(
69
69
self ._auth_uri = "{}/{}" .format (self ._auth_uri , self ._entity_name )
70
70
# Internal flag for switching whether to apply connection sharing, pending fix in uamqp library
71
71
self ._connection_sharing = False
72
- self ._handlers = []
72
+ self ._handlers = [] # type: List[BaseHandler]
73
73
74
74
def __enter__ (self ):
75
75
if self ._connection_sharing :
Original file line number Diff line number Diff line change 2
2
# Copyright (c) Microsoft Corporation. All rights reserved.
3
3
# Licensed under the MIT License. See License.txt in the project root for license information.
4
4
# --------------------------------------------------------------------------------------------
5
- from typing import Any , TYPE_CHECKING
5
+ from typing import Any , List , TYPE_CHECKING
6
6
7
7
import uamqp
8
8
9
9
from .._base_handler import _parse_conn_str
10
- from ._base_handler_async import ServiceBusSharedKeyCredential
10
+ from ._base_handler_async import ServiceBusSharedKeyCredential , BaseHandler
11
11
from ._servicebus_sender_async import ServiceBusSender
12
12
from ._servicebus_receiver_async import ServiceBusReceiver
13
13
from ._servicebus_session_receiver_async import ServiceBusSessionReceiver
@@ -71,7 +71,7 @@ def __init__(
71
71
self ._auth_uri = "{}/{}" .format (self ._auth_uri , self ._entity_name )
72
72
# Internal flag for switching whether to apply connection sharing, pending fix in uamqp library
73
73
self ._connection_sharing = False
74
- self ._handlers = []
74
+ self ._handlers = [] # type: List[BaseHandler]
75
75
76
76
async def __aenter__ (self ):
77
77
if self ._connection_sharing :
You can’t perform that action at this time.
0 commit comments