GraphReentryQueue
GraphReentryQueue
Section titled “GraphReentryQueue”Kind: class
Source: src/graphrefly/_facade.py:761
Signature
Section titled “Signature”GraphReentryQueue(*, owner_thread: int, lifetime: _GraphLifetime, _token: object | None = None)Description
Section titled “Description”Owner-thread drain gate for GraphReFly-owned async completions.
Attributes
Section titled “Attributes”| Name | Type | Description |
|---|---|---|
closed | bool | Return whether this re-entry queue has been closed. |
pending_count | int | Return the number of private completions waiting to drain. |
Methods
Section titled “Methods”wrap_runner
Section titled “wrap_runner”wrap_runner(runner: AsyncRunner) -> AsyncRunnerReturn an AsyncRunner adapter whose completions are drained by this queue.
Source: src/graphrefly/_facade.py:798
drain(max_items: int | None = None) -> intDrain queued private completions on the graph owner thread.
Source: src/graphrefly/_facade.py:806
close() -> NoneClose this queue and cancel queued private completions.
Source: src/graphrefly/_facade.py:834