|
|
@ -1103,7 +1103,8 @@ class TestAsyncServer: |
|
|
raise TypeError("Unknown type") |
|
|
raise TypeError("Unknown type") |
|
|
args = {"dumps_default": default} |
|
|
args = {"dumps_default": default} |
|
|
data = {"current": datetime.now(timezone(timedelta(0)))} |
|
|
data = {"current": datetime.now(timezone(timedelta(0)))} |
|
|
s = async_server.AsyncServer(serializer='msgpack', serializer_args=args) |
|
|
s = async_server.AsyncServer(serializer='msgpack', |
|
|
|
|
|
serializer_args=args) |
|
|
p = s._create_packet(data=data) |
|
|
p = s._create_packet(data=data) |
|
|
p2 = s._create_packet(encoded_packet=p.encode()) |
|
|
p2 = s._create_packet(encoded_packet=p.encode()) |
|
|
|
|
|
|
|
|
@ -1115,6 +1116,7 @@ class TestAsyncServer: |
|
|
|
|
|
|
|
|
def test_invalid_serializer_args(self, eio): |
|
|
def test_invalid_serializer_args(self, eio): |
|
|
args = {"invalid_arg": 123} |
|
|
args = {"invalid_arg": 123} |
|
|
s = async_server.AsyncServer(serializer='msgpack', serializer_args=args) |
|
|
s = async_server.AsyncServer(serializer='msgpack', |
|
|
|
|
|
serializer_args=args) |
|
|
with pytest.raises(TypeError): |
|
|
with pytest.raises(TypeError): |
|
|
s._create_packet(data={"foo": "bar"}).encode() |
|
|
s._create_packet(data={"foo": "bar"}).encode() |