'When ``connnected()`` is called a ``_ConnectedToControlService`` input
is passed to the cluster status FSM.'

def test_connected(self):

    service = self.service
    service.cluster_status = fsm = StubFSM()
    client = connected_amp_protocol()
    service.connected(client)
    self.assertEqual(fsm.inputted, [_ConnectedToControlService(client=client)])
