

def AsyncProcessResponse(self, stream, msg):
    stream.processed_response = True
    self.return_message = msg
    self.return_stream = stream
    super(MockSinkStack, self).AsyncProcessResponse(stream, msg)

dataset/ETHPy150Open steveniemitz/scales/test/scales/util/mocks.py MockSinkStack.AsyncProcessResponse/VarMisuse@14/17 `self`->`stream`