'Set up a stream, and act as if session establishment succeeds.'

def testSuccess(self):

    def onSession(iq):
        response = xmlstream.toResponse(iq, 'result')
        self.pipe.source.send(response)
    d1 = self.waitFor(IQ_SESSION_SET, onSession)
    d2 = self.init.start()
    return defer.gatherResults([d1, d2])
