

def AsyncProcessResponse(self, sink_stack, context, stream, msg):
    if self.ProcessResponse:
        self.ProcessResponse(sink_stack, context, stream, msg)

dataset/ETHPy150Open steveniemitz/scales/test/scales/util/mocks.py MockSink.AsyncProcessResponse/original