Coverage for faststream / _internal / basic_types.py: 64%

1from collections.abc import Awaitable, Callable, Mapping, Sequence (empty)

2from contextlib import AbstractAsyncContextManager (empty)

3from datetime import datetime (empty)

4from decimal import Decimal (empty)

5from typing import ( (empty)

6 Any, 

7 ClassVar, 

8 Protocol, 

9 TypeAlias, 

10 TypeVar, 

11) 

12 

13from typing_extensions import ParamSpec (empty)

14 

15AnyHttpUrl: TypeAlias = str (empty)

16 

17F_Return = TypeVar("F_Return") (empty)

18F_Spec = ParamSpec("F_Spec") (empty)

19 

20AnyCallable: TypeAlias = Callable[..., Any] (empty)

21NoneCallable: TypeAlias = Callable[..., None] (empty)

22AsyncFunc: TypeAlias = Callable[..., Awaitable[Any]] (empty)

23AsyncFuncAny: TypeAlias = Callable[[Any], Awaitable[Any]] (empty)

24 

25DecoratedCallable: TypeAlias = AnyCallable (empty)

26DecoratedCallableNone: TypeAlias = NoneCallable (empty)

27 

28Decorator: TypeAlias = Callable[[AnyCallable], AnyCallable] (empty)

29 

30JsonArray: TypeAlias = Sequence["DecodedMessage"] (empty)

31 

32JsonTable: TypeAlias = dict[str, "DecodedMessage"] (empty)

33 

34JsonDecodable: TypeAlias = bool | bytes | bytearray | float | int | str | None (empty)

35 

36DecodedMessage: TypeAlias = JsonDecodable | JsonArray | JsonTable (empty)

37 

38SendableArray: TypeAlias = Sequence["BaseSendableMessage"] (empty)

39 

40SendableTable: TypeAlias = dict[str, "BaseSendableMessage"] (empty)

41 

42 

43class StandardDataclass(Protocol): (empty)

44 """Protocol to check type is dataclass.""" 

45 

46 __dataclass_fields__: ClassVar[dict[str, Any]] (empty)

47 

48 

49BaseSendableMessage: TypeAlias = ( (empty)

50 JsonDecodable 

51 | Decimal 

52 | datetime 

53 | StandardDataclass 

54 | SendableTable 

55 | SendableArray 

56 | None 

57) 

58 

59try: (empty)

60 from pydantic import BaseModel (empty)

61 

62 HAS_PYDANTIC = True (empty)

63except ImportError: 

64 HAS_PYDANTIC = False 

65 

66try: (empty)

67 from msgspec import Struct (empty)

68 

69 HAS_MSGSPEC = True (empty)

70except ImportError: 

71 HAS_MSGSPEC = False 

72 

73if HAS_PYDANTIC and HAS_MSGSPEC: 73 ↛ 75line 73 didn't jump to line 75 because the condition on line 73 was always true(empty)

74 SendableMessage: TypeAlias = Struct | BaseModel | BaseSendableMessage (empty)

75elif HAS_PYDANTIC: 

76 SendableMessage: TypeAlias = BaseModel | BaseSendableMessage # type: ignore[no-redef,misc] 

77elif HAS_MSGSPEC: 

78 SendableMessage: TypeAlias = Struct | BaseSendableMessage # type: ignore[no-redef,misc] 

79else: 

80 SendableMessage: TypeAlias = BaseSendableMessage # type: ignore[no-redef,misc] 

81 

82SettingField: TypeAlias = ( (empty)

83 bool | str | list[bool | str] | list[str] | list[bool] | int | None 

84) 

85 

86Lifespan: TypeAlias = Callable[..., AbstractAsyncContextManager[None]] (empty)

87 

88 

89class LoggerProto(Protocol): (empty)

90 def log( (empty)

91 self, 

92 level: int, (empty)

93 msg: Any, (empty)

94 /, 

95 *, 

96 exc_info: Any = None, (empty)

97 extra: Mapping[str, Any] | None = None, (empty)

98 ) -> None: ... (empty)