Supplier<Object> supplier = () -> null;

        monitorTarget.append(buf, "testKey", supplier);
        assertEquals("\"testKey\":null", buf.toString());
    }

    // Test append method with Integer value
    @Test
    public void test_append_integerValue() {
        StringBuilder buf = new StringBuilder();
        Supplier<Object> supplier = () -> Integer.valueOf(123);

    override fun createSocket(): Socket {
      return object : Socket() {
        override fun connect(
          endpoint: SocketAddress?,
          timeout: Int,
        ) {
          onConnect(timeout)
          super.connect(endpoint, timeout)
        }

        override fun getInputStream(): InputStream {
          return object : FilterInputStream(super.inputStream) {
            override fun read(

    return (Collector) TO_OPTIONAL;
  }

  private static final Object NULL_PLACEHOLDER = new Object();

  private static final Collector<@Nullable Object, ?, @Nullable Object> ONLY_ELEMENT =
      Collector.<@Nullable Object, ToOptionalState<Object>, @Nullable Object>of(
          () -> new ToOptionalState<>(null),
          (state, o) -> state.add((o == null) ? NULL_PLACEHOLDER : o),

    /**
     * Returns {@literal true} if the object is an array. Returns {@literal false} if the object is {@literal null}.
     *
     * @param object
     *            the object
     * @return {@literal true} if the object is an array; {@literal false} if the object is {@literal null}
     */
    public static boolean isArray(final Object object) {
        return object != null && object.getClass().isArray();
    }

        Assertions.assertEquals(expected, actual, message);
    }

    // assertEquals - JUnit 4 style (message first) - int version
    protected void assertEquals(String message, int expected, int actual) {
        Assertions.assertEquals(expected, actual, message);
    }

    // assertSame - JUnit 5 style (no message)
    protected void assertSame(Object expected, Object actual) {

    }

    @Input
    public Map<String, Object> getHostEnv() {
        return hostEnv.get();
    }

    public void hostEnv(String name, Object value) {
        hostEnv.put(name, value);
    }

    @Input
    public Map<String, Object> getVmEnv() {
        return vmEnv.get();
    }

    public void vmEnv(String name, Object value) {
        vmEnv.put(name, value);
    }

    @Input

        // Test with supported document type
        Map<String, Object> docMap = new HashMap<>();
        docMap.put("mimetype", "application/pdf");
        assertTrue(thumbnailGenerator.isTarget(docMap));
    }

    @Test
    public void test_isTarget_withUnsupportedMimeType() {
        // Test with unsupported document type
        Map<String, Object> docMap = new HashMap<>();

import java.util.concurrent.ExecutionException;
import org.jspecify.annotations.Nullable;

/**
 * A semi-persistent mapping from keys to values. Cache entries are manually added using {@link
 * #get(Object, Callable)} or {@link #put(Object, Object)}, and are stored in the cache until either
 * evicted or manually invalidated. The common way to build instances is using {@link CacheBuilder}.
 *

            processor.init();

            // Should handle exception gracefully and return results from working searcher
            final List<Map<String, Object>> results = processor.search("*", new TestSearchRequestParams(0, 10, 0), OptionalThing.empty());
            assertNotNull(results);
        }
    }

    /**

    @Override
    public E remove() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove();
    }

    @Override
    public boolean remove(Object object) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.remove(object);
    }

    @Override
    public @Nullable E peek() {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.peek();
    }

    @Override