Method join

test/helpers.py:150–152 · view source on GitHub ↗

(self, timeout: Optional[float] = None)

Source from the content-addressed store, hash-verified

148	self.task = create_task(self.run(), name=self.name)
149
150	def join(self, timeout: Optional[float] = None): # type: ignore[override]
151	if self.task is not None:
152	asyncio.wait([self.task], timeout=timeout)
153
154	def is_alive(self):
155	return not self.stopped

test_change_streamsMethod · 0.95

test_connection_close_does_not_block_other_operationsMethod · 0.95

test_heartbeat_start_orderingMethod · 0.95

apply_replacementsFunction · 0.45

_read_size_or_lineMethod · 0.45

test_pool_paused_error_is_retryableMethod · 0.45

test_client_backpressure.pyFile · 0.45

_test_no_gc_deadlockMethod · 0.45

test_session_gcMethod · 0.45

test_uri_spec.pyFile · 0.45

create_testsFunction · 0.45

waitMethod · 0.45

test_change_streamsMethod · 0.76

test_connection_close_does_not_block_other_operationsMethod · 0.76

test_heartbeat_start_orderingMethod · 0.76

apply_replacementsFunction · 0.36

test_pool_paused_error_is_retryableMethod · 0.36

_test_no_gc_deadlockMethod · 0.36

test_session_gcMethod · 0.36

create_testsFunction · 0.36

create_selection_testsFunction · 0.36

wait_for_threadMethod · 0.36

cleanupMethod · 0.36