Pika 的 Twisted 示例代码中的设置如下所示:
parameters = pika.ConnectionParameters()
cc = protocol.ClientCreator(
reactor, twisted_connection.TwistedProtocolConnection, parameters)
d = cc.connectTCP('hostname', 5672)
d.addCallback(lambda protocol: protocol.ready)
d.addCallback(run)
reactor.run()
d.addCallback(lambda protocol: protocol.ready)
线路有什么作用?读取.ready
属性是否有副作用?还是addCallback
使用回调的返回值?