Coverage for faststream / redis / schemas / proto.py: 44%

1from faststream.exceptions import SetupError (empty)

2 

3from .list_sub import ListSub (empty)

4from .pub_sub import PubSub (empty)

5from .stream_sub import StreamSub (empty)

6 

7 

8def validate_options( (empty)

9 *, 

10 channel: PubSub | str | None, 

11 list: ListSub | str | None, 

12 stream: StreamSub | str | None, 

13) -> None: 

14 if all((channel, list)): 14 ↛ 15line 14 didn't jump to line 15 because the condition on line 14 was never true(empty)

15 msg = "You can't use `PubSub` and `ListSub` both" 

16 raise SetupError(msg) 

17 if all((channel, stream)): 17 ↛ 18line 17 didn't jump to line 18 because the condition on line 17 was never true(empty)

18 msg = "You can't use `PubSub` and `StreamSub` both" 

19 raise SetupError(msg) 

20 if all((list, stream)): 20 ↛ 21line 20 didn't jump to line 21 because the condition on line 20 was never true(empty)

21 msg = "You can't use `ListSub` and `StreamSub` both" 

22 raise SetupError(msg)