ThumbnailQueueCQ cq = new ThumbnailQueueCQ();
        if (queryLambda != null) {
            queryLambda.callback(cq);
        }
        FilterAggregationBuilder builder = regFilterA(name, cq.getQuery());
        if (opLambda != null) {
            opLambda.callback(builder);
        }
        if (aggsLambda != null) {
            ThumbnailQueueCA ca = new ThumbnailQueueCA();
            aggsLambda.callback(ca);

  /**
   * The reason why this stream was closed, or null if it closed normally or has not yet been
   * closed.
   *
   * If there are multiple reasons to abnormally close this stream (such as both peers closing it
   * near-simultaneously) then this is the first reason known to this peer.
   */
  internal var errorCode: ErrorCode? = null
    get() = withLock { field }

        this.syncContextFactory = Objects.requireNonNull(syncContextFactory, "syncContextFactory cannot be null");
        this.repositoryEventDispatcher =
                Objects.requireNonNull(repositoryEventDispatcher, "repositoryEventDispatcher cannot be null");
        this.versionScheme = Objects.requireNonNull(versionScheme, "versionScheme cannot be null");
    }

    @Override

    }

    private String join(String message1, String message2) {
        String message = "";

        if (message1 != null && !message1.isEmpty()) {
            message = message1.trim();
        }

        if (message2 != null && !message2.isEmpty()) {
            if (message != null && !message.isEmpty()) {
                if (message.endsWith(".") || message.endsWith("!") || message.endsWith(":")) {

            long id = 0;
            String line = null;
            while ((line = reader.readLine()) != null) {
                if (line.length() == 0 || line.charAt(0) == '#') {
                    if (updater != null) {
                        updater.write(line);
                    }
                    continue; // ignore empty lines and comments

    if (result != null) {
      return result;
    } else {
      return defaultValue;
    }
  }

  private transient @Nullable ImmutableSet<Entry<K, V>> cachedEntrySet = null;

  @Override
  public final ImmutableSet<Entry<K, V>> entrySet() {
    if (cachedEntrySet != null) {
      return cachedEntrySet;
    }

     * @return merged Properties if NTLM auth is found, null otherwise
     */
    protected Properties collectNtlmParameters() {
        if (initParamMap == null) {
            return null;
        }
        final Object value = initParamMap.get(AUTHENTICATIONS_PROPERTY);
        if (value == null) {
            return null;
        }

        Properties result = null;

            @Override
            protected SmbResource adapt(FileEntry e) throws MalformedURLException {
                return null;
            }
        };

        // When all entries return null, iterator should be empty
        assertFalse(iterator.hasNext());
        assertNull(iterator.next());
    }

    return null;
  }

  @CanIgnoreReturnValue
  @Override
  public @Nullable V put(K key, V value) {
    synchronized (lock) {
      checkNotNull(key);
      checkNotNull(value);
      Timestamped<V> oldValue = cachingHashMap.put(key, new Timestamped<V>(value, ticker));
      if (oldValue == null) {
        return null;
      }

    public void test_maskSensitiveValue_nullHandling() {
        // When key is null, cannot determine if sensitive, so return value as-is
        assertEquals("value", SystemUtil.maskSensitiveValue(null, "value"));
        // When value is null, return null
        assertNull(SystemUtil.maskSensitiveValue("key", null));
        assertNull(SystemUtil.maskSensitiveValue(null, null));
    }

    @Test