Blob Blame History Raw
*** 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):