用于 Twisted 中的 Protocol.dataReceived 的 inlineCallbacks

Question

我似乎误解了dataReceived和inlineCallbacks的规则。

更具体地说，当我这样做时：

def dataReceived(self, data):
    self.transport.write('ok')

我的协议确实发送了数据，但是当我这样做时：

@defer.inlineCallbacks
def dataReceived(self, data):
    a = yield True # this stands for some adbapi call actually
    self.transport.write('ok')

我什么也没收到，然后连接就关闭了。 defer.returnValue 在这里也没有帮助，行为只是相似的。

请解释一下。

Answer 1

这只是一种预感，但我认为 dataReceived() 函数不会返回任何内容，因此 inlineCallbacks 甚至返回/产生常规 Deferred 不会真正“做任何事情”。很抱歉模棱两可。您可能应该做的是创建一个Deferred 并在您的dataReceived() 函数中启动一个回调链。例如：

def dataReceived(self, data):
    # ...
    deferredObj = adbapi.runQuery('SELECT * FROM ...')    # this returns a Deferred
    deferredObj.addCallback(self.someCallback)            # exec self.someCallback() after query returns
    deferredObj.addErrback(self.anotherCallback, *args, **kwargs)

def someCallback(self, result):
    """
    When the db query returns, do something useful here
    """
    print(result)

链接

• Twisted Async adbapi Example