def testConnectSucceeds(self):
        self.failUnless(self.scheduled, "No connect timeout scheduled.") # Sanity check
        self.rdm.addOutput(mappend(self.transport))
        n, f, a, kw = self.scheduled.pop()
        self.assertEquals(n, self.idleTimeout)
        self.failIf(self.scheduled, "Output channel added but there is still a task pending.")
        self.assertEquals(self.transport, [], "Received unexpected output.")
Gets info about a file partition for parallel file/object transfers.
dataset/ETHPy150Open twisted/nevow/nevow/test/test_athena.py/Transport.testConnectSucceeds--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/gsutil/gslib/copy_helper.py/_GetPartitionInfo