|
1 | 1 | from _typeshed import structseq |
2 | | -from typing import Final, Literal, SupportsIndex, final |
| 2 | +from typing import Any, Final, Literal, SupportsIndex, final |
3 | 3 | from typing_extensions import Buffer, Self |
4 | 4 |
|
5 | 5 | class ChannelError(RuntimeError): ... |
@@ -72,13 +72,15 @@ class ChannelInfo(structseq[int], tuple[bool, bool, bool, int, int, int, int, in |
72 | 72 | @property |
73 | 73 | def send_released(self) -> bool: ... |
74 | 74 |
|
75 | | -def create() -> ChannelID: ... |
| 75 | +def create(unboundop: Literal[1, 2, 3]) -> ChannelID: ... |
76 | 76 | def destroy(cid: SupportsIndex) -> None: ... |
77 | 77 | def list_all() -> list[ChannelID]: ... |
78 | 78 | def list_interpreters(cid: SupportsIndex, *, send: bool) -> list[int]: ... |
79 | 79 | def send(cid: SupportsIndex, obj: object, *, blocking: bool = True, timeout: float | None = None) -> None: ... |
80 | 80 | def send_buffer(cid: SupportsIndex, obj: Buffer, *, blocking: bool = True, timeout: float | None = None) -> None: ... |
81 | | -def recv(cid: SupportsIndex, default: object = ...) -> object: ... |
| 81 | +def recv(cid: SupportsIndex, default: object = ...) -> tuple[Any, Literal[1, 2, 3]]: ... |
82 | 82 | def close(cid: SupportsIndex, *, send: bool = False, recv: bool = False) -> None: ... |
| 83 | +def get_count(cid: SupportsIndex) -> int: ... |
83 | 84 | def get_info(cid: SupportsIndex) -> ChannelInfo: ... |
| 85 | +def get_channel_defaults(cid: SupportsIndex) -> Literal[1, 2, 3]: ... |
84 | 86 | def release(cid: SupportsIndex, *, send: bool = False, recv: bool = False, force: bool = False) -> None: ... |
0 commit comments