diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-14 13:34:37 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-14 13:34:37 -0700 |
| commit | 65ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e (patch) | |
| tree | c5b7144b04c9238ae459d80339f27b6af33b5a5c /test/test_client_async.py | |
| parent | a00f9ead161e8b05ac953b460950e42fa0e0b7d6 (diff) | |
| download | kafka-python-65ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e.tar.gz | |
Derive all api classes from Request / Response base classes (#1030)
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): |