code: def execute_op_msg_no_results(self, sock_info, generator):
          
          db_name = self.collection.database.name
          client = self.collection.database.client
          listeners = client._event_listeners
          op_id = _randint()
  
          if not self.current_run:
              self.current_run = next(generator)
          run = self.current_run
  
          while run:
              cmd = SON([(_COMMANDS[run.op_type], self.collection.name),
                         ('ordered', False),
                         ('writeConcern', {'w': 0})])
              bwc = _BulkWriteContext(db_name, cmd, sock_info, op_id,
                                      listeners, None)
  
              while run.idx_offset < len(run.ops):
                  check_keys = run.op_type == _INSERT
                  ops = islice(run.ops, run.idx_offset, None)
                  # Run as many ops as possible.
                  request_id, msg, to_send = _do_bulk_write_command(
                      self.namespace, run.op_type, cmd, ops, check_keys,
                      self.collection.codec_options, bwc)
                  if not to_send:
                      raise InvalidOperation("cannot do an empty bulk write")
                  run.idx_offset += len(to_send)
                  # Though this isn't strictly a "legacy" write, the helper
                  # handles publishing commands and sending our message
                  # without receiving a result. Send 0 for max_doc_size
                  # to disable size checking. Size checking is handled while
                  # the documents are encoded to BSON.
                  bwc.legacy_write(request_id, msg, 0, False, to_send)
              self.current_run = run = next(generator, None)
docs: Execute write commands with OP_MSG and w=0 writeConcern, unordered.