4 from collections
import deque
7 from juju
.client
.connection
import Connection
11 def __init__(self
, responses
):
13 self
.responses
= deque(responses
)
16 async def send(self
, message
):
20 return json
.dumps(self
.responses
.popleft())
22 async def close(self
):
27 async def test_out_of_order(event_loop
):
28 con
= Connection(*[None]*4)
34 expected_responses
= [
39 con
._get
_sll
= mock
.MagicMock()
40 with mock
.patch('websockets.connect', base
.AsyncMock(return_value
=ws
)):
44 actual_responses
.append(await con
.rpc({'version': 1}))
45 assert actual_responses
== expected_responses