def connect(self):
        raise NotImplementedError()
Return a future which completes when connected to the remote publisher
dataset/ETHPy150Open saltstack/salt/salt/transport/client.py/AsyncPubChannel.connect