diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-12 19:57:36 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-13 11:16:18 -0700 |
| commit | 894cfec656e44f92766775baf84cfd1d2e257901 (patch) | |
| tree | 541b9074d0ea4aa67dc5f64904f7ebd3f44c2549 /test/test_client_async.py | |
| parent | 899f11730db5f209c03cfad20111ec131ee4c70b (diff) | |
| download | kafka-python-request_response_classes.tar.gz | |
Derive all api classes from Request / Response base classesrequest_response_classes
Diffstat (limited to 'test/test_client_async.py')
| -rw-r--r-- | test/test_client_async.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/test_client_async.py b/test/test_client_async.py index 8874c67..97be827 100644 --- a/test/test_client_async.py +++ b/test/test_client_async.py @@ -236,13 +236,14 @@ def test_send(cli, conn): cli._maybe_connect(0) # ProduceRequest w/ 0 required_acks -> no response request = ProduceRequest[0](0, 0, []) + assert request.expect_response() is False ret = cli.send(0, request) - assert conn.send.called_with(request, expect_response=False) + assert conn.send.called_with(request) assert isinstance(ret, Future) request = MetadataRequest[0]([]) cli.send(0, request) - assert conn.send.called_with(request, expect_response=True) + assert conn.send.called_with(request) def test_poll(mocker): |