From d61e861b0da1647974e617e1633c429c307789be Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 4 Apr 2016 18:57:32 -0700 Subject: Consolidate conn fixture definitions --- test/test_client_async.py | 15 --------------- 1 file changed, 15 deletions(-) (limited to 'test/test_client_async.py') diff --git a/test/test_client_async.py b/test/test_client_async.py index 2cf348c..c326d55 100644 --- a/test/test_client_async.py +++ b/test/test_client_async.py @@ -31,21 +31,6 @@ def test_bootstrap_servers(mocker, bootstrap, expected_hosts): assert sorted(hosts) == sorted(expected_hosts) -@pytest.fixture -def conn(mocker): - conn = mocker.patch('kafka.client_async.BrokerConnection') - conn.return_value = conn - conn.state = ConnectionStates.CONNECTED - conn.send.return_value = Future().success( - MetadataResponse[0]( - [(0, 'foo', 12), (1, 'bar', 34)], # brokers - [])) # topics - conn.blacked_out.return_value = False - conn.connect.side_effect = lambda: conn.state - conn.connected = lambda: conn.connect() is ConnectionStates.CONNECTED - return conn - - def test_bootstrap_success(conn): conn.state = ConnectionStates.CONNECTED cli = KafkaClient() -- cgit v1.2.1