public ElevateWordCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsElevateWordCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (ElevateWordCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public JobLogCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsJobLogCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (JobLogCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public PathMappingCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsPathMappingCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (PathMappingCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public ThumbnailQueueCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsThumbnailQueueCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (ThumbnailQueueCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

      }
    }
  }

  private fun readAndWriteFrames() {
    check(socket == null)
    val socket = serverSocket!!.accept()!!
    this.socket = socket

    // Bail out now if this instance was closed while waiting for the socket to accept.
    synchronized(this) {
      if (executor.isShutdown) {
        socket.close()
        return
      }
    }

  }

  /**
   * Enters this monitor. Blocks at most the given time.
   *
   * @return whether the monitor was entered
   */
  @SuppressWarnings("GoodTime") // should accept a java.time.Duration
  public boolean enter(long time, TimeUnit unit) {
    long timeoutNanos = toSafeNanos(time, unit);
    ReentrantLock lock = this.lock;
    if (!fair && lock.tryLock()) {
      return true;

                assertEquals("(memberOf=%s)", groupFilter);

                // Test callback
                String[] callbackRoles = new String[] { "role1", "role2" };
                callback.accept(callbackRoles);
                rolesFromCallback.set(callbackRoles);

                // Return roles from LDAP
                return new String[] { "Rgroup1", "Rgroup2" };
            }

        return super.writeReplace();
      }
    };
  }

  @GwtIncompatible
  @Override
  public void forEach(Consumer<? super V> action) {
    checkNotNull(action);
    map.forEach((k, v) -> action.accept(v));
  }

  // redeclare to help optimizers with b/310253115
  @SuppressWarnings("RedundantOverride")
  @Override
  @J2ktIncompatible
  @GwtIncompatible
    Object writeReplace() {

    public DuplicateHostCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsDuplicateHostCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (DuplicateHostCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public RelatedQueryCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsRelatedQueryCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (RelatedQueryCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }