def METHOD_NAME(self, local_init_net, local_finish_net):
    self._wrapper._new_reader(local_init_net)
    dequeue_net = core.Net('dequeue')
    fields, status_blob = dequeue(
        dequeue_net,
        self._wrapper.queue(),
        len(self.schema().field_names()),
        field_names=self.schema().field_names(),
        num_records=self._num_dequeue_records)
    return [dequeue_net], status_blob, fields