Experimental extension to the interface. Don't use yet.
(
self, fields, local_init_net, local_finish_net, stop_blob=None)
| 187 | return [write_net] |
| 188 | |
| 189 | def write_record_ex( |
| 190 | self, fields, local_init_net, local_finish_net, stop_blob=None): |
| 191 | """Experimental extension to the interface. Don't use yet.""" |
| 192 | if isinstance(fields, Field): |
| 193 | self._schema = fields |
| 194 | fields = fields.field_blobs() |
| 195 | if stop_blob is None: |
| 196 | stop_blob = local_init_net.NextName("dequeue_status") |
| 197 | write_nets = self.write_ex( |
| 198 | fields, local_init_net, local_finish_net, stop_blob) |
| 199 | return (write_nets, stop_blob) |
| 200 | |
| 201 | def commit(self, finish_net): |
| 202 | """Add operations to `finish_net` that signal end of data. |
no test coverage detected