diff options
author | Dana Powers <dana.powers@rd.io> | 2018-03-07 18:05:59 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2018-03-07 18:05:59 -0800 |
commit | d40a440a79626eb678cc12b5893d8be769b2c04d (patch) | |
tree | 25c3a53e56792b41c76079e068cfaa2232ded80c | |
parent | 33577d8d1e5fe201adc61b4c1661396c729ae0c0 (diff) | |
download | kafka-python-d40a440a79626eb678cc12b5893d8be769b2c04d.tar.gz |
Test BrokerConnection.connection_delay()
-rw-r--r-- | test/test_conn.py | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/test/test_conn.py b/test/test_conn.py index 5698519..f35cebe 100644 --- a/test/test_conn.py +++ b/test/test_conn.py @@ -72,6 +72,15 @@ def test_blacked_out(conn): assert conn.blacked_out() is True +def test_connection_delay(conn): + conn.last_attempt = time.time() + assert round(conn.connection_delay()) == round(conn.config['reconnect_backoff_ms']) + conn.state = ConnectionStates.CONNECTING + assert conn.connection_delay() == 0 + conn.state = ConnectionStates.CONNECTED + assert conn.connection_delay() == float('inf') + + def test_connected(conn): assert conn.connected() is False conn.state = ConnectionStates.CONNECTED |