IQ.Lvbs/pycapnp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Make a server fail early when the KJ loop is not running

Browse Source
This commit is contained in:
Lasse Blaauwbroek
2023-10-15 12:52:32 +02:00
committed by Jacob Alexander
parent cc088211dc
commit 1446386636
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
capnp/lib/capnp.pyx
View File

@@ -2403,6 +2403,9 @@ cdef class _AsyncIoStream:
for `callback` will be passed directly to that function, and the server returned is similar as well. for `callback` will be passed directly to that function, and the server returned is similar as well.
See that function for documentation on the possible arguments. See that function for documentation on the possible arguments.
""" """
# Fail early in case the kj loop is not running. Without this, the error is thrown when a connection is made.
# Unless asyncio is in debug mode, that error is swallowed.
C_DEFAULT_EVENT_LOOP_GETTER()
loop = asyncio.get_running_loop() loop = asyncio.get_running_loop()
return await loop.create_server(lambda: _AsyncIoStream._connect(callback), host, port, **kwargs) return await loop.create_server(lambda: _AsyncIoStream._connect(callback), host, port, **kwargs)
@@ -2417,6 +2420,9 @@ cdef class _AsyncIoStream:
for `callback` will be passed directly to that function, and the server returned is similar as well. for `callback` will be passed directly to that function, and the server returned is similar as well.
See that function for documentation on the possible arguments. See that function for documentation on the possible arguments.
""" """
# Fail early in case the kj loop is not running. Without this, the error is thrown when a connection is made.
# Unless asyncio is in debug mode, that error is swallowed.
C_DEFAULT_EVENT_LOOP_GETTER()
loop = asyncio.get_running_loop() loop = asyncio.get_running_loop()
return await loop.create_unix_server(lambda: _AsyncIoStream._connect(callback), path, **kwargs) return await loop.create_unix_server(lambda: _AsyncIoStream._connect(callback), path, **kwargs)