Coverage for tests / examples / nats / test_e07_object_storage.py: 80%

1import pytest (empty)

2 

3from faststream import TestApp (empty)

4from faststream.nats import TestNatsBroker (empty)

5 

6 

7@pytest.mark.connected() (empty)

8@pytest.mark.asyncio() (empty)

9@pytest.mark.nats() (empty)

10async def test_basic() -> None: (empty)

11 from examples.nats.e07_object_storage import app, broker, handler (empty)

12 

13 async with TestNatsBroker(broker, with_real=True): (empty)

14 await broker.start() (empty)

15 

16 os = await broker.object_storage("example-bucket") (empty)

17 try: (empty)

18 existed_files = await os.list() (empty)

19 except Exception: 

20 existed_files = () 

21 

22 call = True (empty)

23 for file in existed_files: (empty)

24 if file.name == "file.txt": 24 ↛ 23line 24 didn't jump to line 23 because the condition on line 24 was always true(empty)

25 call = False (empty)

26 

27 if call: 27 ↛ 28line 27 didn't jump to line 28 because the condition on line 27 was never true(empty)

28 async with TestApp(app): 

29 pass 

30 

31 await handler.wait_call(3.0) (empty)

32 handler.mock.assert_called_once_with("file.txt") (empty)