

def AsyncProcessRequest(self, sink_stack, msg, stream, headers):
    if self.ProcessRequest:
        self.ProcessRequest(sink_stack, msg, stream, headers)
    elif self.is_closed:
        self.AsyncProcessResponseMessage(MethodReturnMessage(error=FailedFastError()))

dataset/ETHPy150Open steveniemitz/scales/test/scales/util/mocks.py MockSink.AsyncProcessRequest/VarMisuse@46/58 `sink_stack`->`self`