'If execution of the command is cancelled via the L{Deferred} returned
by L{SSHCommandClientEndpoint.connect}, the connection is closed
immediately.'

def test_execCancelled(self):

    self.realm.channelLookup['session'] = UnsatisfiedExecSession
    endpoint = self.create()
    factory = Factory()
    factory.protocol = Protocol
    connected = endpoint.connect(factory)
    (server, client, pump) = self.finishConnection()
    connected.cancel()
    f = self.failureResultOf(connected)
    f.trap(CancelledError)
    self.assertClientTransportState(client, True)
