Merge pull request #636 from dpkp/french_connection

Simplify connection logic

1 files changed, 0 insertions, 13 deletions

diff --git a/test/test_coordinator.py b/test/test_coordinator.py
index 629b72f..399609d 100644
--- a/test/test_coordinator.py
+++ b/test/test_coordinator.py
@@ -12,7 +12,6 @@ from kafka.coordinator.assignors.roundrobin import RoundRobinPartitionAssignor
 from kafka.coordinator.consumer import ConsumerCoordinator
 from kafka.coordinator.protocol import (
     ConsumerProtocolMemberMetadata, ConsumerProtocolMemberAssignment)
-from kafka.conn import ConnectionStates
 import kafka.errors as Errors
 from kafka.future import Future
 from kafka.protocol.commit import (
@@ -23,18 +22,6 @@ from kafka.util import WeakMethod
 
 
 @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
-    return conn
-
-
-@pytest.fixture
 def coordinator(conn):
     return ConsumerCoordinator(KafkaClient(), SubscriptionState())