Change type of read_min_bytes from size to int

Not sure why this was not causing issues before or if that is the right fix ... but it seems to be fine :)
tobiasah · Oct 3, 2023 · 6d9ac69 · 6d9ac69
1 parent 313d0d4
commit 6d9ac69
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/capnp/lib/capnp.pyx b/capnp/lib/capnp.pyx
@@ -2423,7 +2423,7 @@ cdef class _PyAsyncIoStreamProtocol(DummyBaseClass, asyncio.BufferedProtocol):
 
     # State for reading data from the transport
     cdef char* read_buffer
-    cdef size_t read_min_bytes
+    cdef int32_t read_min_bytes
     cdef size_t read_max_bytes
     cdef size_t read_already_read
     cdef PromiseFulfiller[size_t]* read_fulfiller

diff --git a/test/test_load.py b/test/test_load.py
@@ -144,6 +144,7 @@ async def wrapped(self, object, **kwargs):
     baz_.text = "test"
     baz_.qux.id = 2
 
-    wrapper = foo.Wrapper._new_client(Wrapper())
-    remote = wrapper.wrapped(baz_)
-    await remote
+    async with capnp.kj_loop():
+        wrapper = foo.Wrapper._new_client(Wrapper())
+        remote = wrapper.wrapped(baz_)
+        await remote