*** test/test_client_async.py.orig Mon Jul 10 23:26:28 2023
--- test/test_client_async.py Tue Jul 11 01:21:31 2023
***************
*** 220,231 ****
request = ProduceRequest[0](0, 0, [])
assert request.expect_response() is False
ret = cli.send(0, request)
! assert conn.send.called_with(request)
assert isinstance(ret, Future)
request = MetadataRequest[0]([])
cli.send(0, request)
! assert conn.send.called_with(request)
def test_poll(mocker):
--- 220,231 ----
request = ProduceRequest[0](0, 0, [])
assert request.expect_response() is False
ret = cli.send(0, request)
! conn.send.assert_called_with(request, blocking=False)
assert isinstance(ret, Future)
request = MetadataRequest[0]([])
cli.send(0, request)
! conn.send.assert_called_with(request, blocking=False)
def test_poll(mocker):