|
71 | 71 |
|
72 | 72 | class Subscription: |
73 | 73 | def __init__( |
74 | | - self, |
75 | | - subject='', |
76 | | - queue='', |
77 | | - future=None, |
78 | | - max_msgs=0, |
79 | | - is_async=False, |
80 | | - cb=None, |
81 | | - coro=None |
| 74 | + self, |
| 75 | + subject='', |
| 76 | + queue='', |
| 77 | + future=None, |
| 78 | + max_msgs=0, |
| 79 | + is_async=False, |
| 80 | + cb=None, |
| 81 | + coro=None |
82 | 82 | ): |
83 | 83 | self.subject = subject |
84 | 84 | self.queue = queue |
@@ -119,6 +119,7 @@ class Srv: |
119 | 119 | """ |
120 | 120 | Srv is a helper data structure to hold state of a server. |
121 | 121 | """ |
| 122 | + |
122 | 123 | def __init__(self, uri): |
123 | 124 | self.uri = uri |
124 | 125 | self.reconnects = 0 |
@@ -228,38 +229,38 @@ def __init__(self): |
228 | 229 | } |
229 | 230 |
|
230 | 231 | async def connect( |
231 | | - self, |
232 | | - servers=["nats://127.0.0.1:4222"], |
233 | | - io_loop=None, |
234 | | - loop=None, |
235 | | - error_cb=None, |
236 | | - disconnected_cb=None, |
237 | | - closed_cb=None, |
238 | | - discovered_server_cb=None, |
239 | | - reconnected_cb=None, |
240 | | - name=None, |
241 | | - pedantic=False, |
242 | | - verbose=False, |
243 | | - allow_reconnect=True, |
244 | | - connect_timeout=DEFAULT_CONNECT_TIMEOUT, |
245 | | - reconnect_time_wait=DEFAULT_RECONNECT_TIME_WAIT, |
246 | | - max_reconnect_attempts=DEFAULT_MAX_RECONNECT_ATTEMPTS, |
247 | | - ping_interval=DEFAULT_PING_INTERVAL, |
248 | | - max_outstanding_pings=DEFAULT_MAX_OUTSTANDING_PINGS, |
249 | | - dont_randomize=False, |
250 | | - flusher_queue_size=DEFAULT_MAX_FLUSHER_QUEUE_SIZE, |
251 | | - pending_size=DEFAULT_PENDING_SIZE, |
252 | | - no_echo=False, |
253 | | - tls=None, |
254 | | - tls_hostname=None, |
255 | | - user=None, |
256 | | - password=None, |
257 | | - token=None, |
258 | | - drain_timeout=DEFAULT_DRAIN_TIMEOUT, |
259 | | - signature_cb=None, |
260 | | - user_jwt_cb=None, |
261 | | - user_credentials=None, |
262 | | - nkeys_seed=None, |
| 232 | + self, |
| 233 | + servers=["nats://127.0.0.1:4222"], |
| 234 | + io_loop=None, |
| 235 | + loop=None, |
| 236 | + error_cb=None, |
| 237 | + disconnected_cb=None, |
| 238 | + closed_cb=None, |
| 239 | + discovered_server_cb=None, |
| 240 | + reconnected_cb=None, |
| 241 | + name=None, |
| 242 | + pedantic=False, |
| 243 | + verbose=False, |
| 244 | + allow_reconnect=True, |
| 245 | + connect_timeout=DEFAULT_CONNECT_TIMEOUT, |
| 246 | + reconnect_time_wait=DEFAULT_RECONNECT_TIME_WAIT, |
| 247 | + max_reconnect_attempts=DEFAULT_MAX_RECONNECT_ATTEMPTS, |
| 248 | + ping_interval=DEFAULT_PING_INTERVAL, |
| 249 | + max_outstanding_pings=DEFAULT_MAX_OUTSTANDING_PINGS, |
| 250 | + dont_randomize=False, |
| 251 | + flusher_queue_size=DEFAULT_MAX_FLUSHER_QUEUE_SIZE, |
| 252 | + pending_size=DEFAULT_PENDING_SIZE, |
| 253 | + no_echo=False, |
| 254 | + tls=None, |
| 255 | + tls_hostname=None, |
| 256 | + user=None, |
| 257 | + password=None, |
| 258 | + token=None, |
| 259 | + drain_timeout=DEFAULT_DRAIN_TIMEOUT, |
| 260 | + signature_cb=None, |
| 261 | + user_jwt_cb=None, |
| 262 | + user_credentials=None, |
| 263 | + nkeys_seed=None, |
263 | 264 | ): |
264 | 265 | for cb in [error_cb, disconnected_cb, closed_cb, reconnected_cb, |
265 | 266 | discovered_server_cb]: |
@@ -675,15 +676,15 @@ async def _publish(self, subject, reply, payload, payload_size): |
675 | 676 | await self._flush_pending() |
676 | 677 |
|
677 | 678 | async def subscribe( |
678 | | - self, |
679 | | - subject, |
680 | | - queue="", |
681 | | - cb=None, |
682 | | - future=None, |
683 | | - max_msgs=0, |
684 | | - is_async=False, |
685 | | - pending_msgs_limit=DEFAULT_SUB_PENDING_MSGS_LIMIT, |
686 | | - pending_bytes_limit=DEFAULT_SUB_PENDING_BYTES_LIMIT, |
| 679 | + self, |
| 680 | + subject, |
| 681 | + queue="", |
| 682 | + cb=None, |
| 683 | + future=None, |
| 684 | + max_msgs=0, |
| 685 | + is_async=False, |
| 686 | + pending_msgs_limit=DEFAULT_SUB_PENDING_MSGS_LIMIT, |
| 687 | + pending_bytes_limit=DEFAULT_SUB_PENDING_BYTES_LIMIT, |
687 | 688 | ): |
688 | 689 | """ |
689 | 690 | Takes a subject string and optional queue string to send a SUB cmd, |
@@ -851,7 +852,7 @@ async def _subscribe(self, sub, ssid): |
851 | 852 | await self._flush_pending() |
852 | 853 |
|
853 | 854 | async def request( |
854 | | - self, subject, payload, timeout=0.5, expected=1, cb=None |
| 855 | + self, subject, payload, timeout=0.5, expected=1, cb=None |
855 | 856 | ): |
856 | 857 | """ |
857 | 858 | Implements the request/response pattern via pub/sub |
|
0 commit comments