Closed lucekdudek closed 3 months ago
asyncio.Semaphore(value=max_size)
ProposalBuffer
condition
ComposableBuffer
Buffer[TItem])
except TimeoutError
except asyncio.TimeoutError
asyncio.Semaphore(value=max_size)toProposalBufferto prevent it from deadlocking (with unit tests)conditionproperty toComposableBufferas it was missing for fullBuffer[TItem])interface implementationexcept TimeoutError->except asyncio.TimeoutError