MCPcopy
hub / github.com/psycopg/psycopg / writer

Function writer

tests/test_waiting_async.py:85–92  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

83 ev = AEvent()
84
85 async def writer():
86 # Wake up the socket, or let it time out, according to the expected `ready`.
87 await ev.wait()
88 assert port
89 await asleep(delay)
90 if ready == waiting.Ready.R:
91 with socket.create_connection(("127.0.0.1", port)):
92 pass
93
94 tasks = [spawn(writer)]
95

Callers

nothing calls this directly

Calls 5

asleepFunction · 0.70
waitMethod · 0.45
closeMethod · 0.45
failMethod · 0.45
setMethod · 0.45

Tested by

no test coverage detected