new ListenerCallQueue.Event<Object>() {
        @Override
        public void call(Object object) {
          throw new RuntimeException();
        }

        @Override
        public String toString() {
          return "throwing()";
        }
      };

  public void testEnqueueAndDispatch() {
    Object listener = new Object();

      new ListenerCallQueue.Event<Object>() {
        @Override
        public void call(Object object) {
          throw new RuntimeException();
        }

        @Override
        public String toString() {
          return "throwing()";
        }
      };

  public void testEnqueueAndDispatch() {
    Object listener = new Object();

        if (queueSize < 1 || batchMaxSize < 1) {
            throw new IllegalArgumentException("Queue and batch sizes must be greater than 1");
        }
        this.batchMaxSize = batchMaxSize;
        this.blockOnLastEvent = blockOnLastEvent;

        this.eventQueue = new ArrayBlockingQueue<>(queueSize);
        this.closed = new AtomicBoolean(false);
        this.updater = new Thread(this::feedConsumer, "simplex-transfer-listener");

        when(mockedPlexusContainer.lookupMap(Lifecycle.class)).thenReturn(lifeCycles);

        DefaultLifecycles dl = new DefaultLifecycles(
                new DefaultLifecycleRegistry(
                        List.of(new DefaultLifecycleRegistry.LifecycleWrapperProvider(mockedPlexusContainer))),
                new DefaultLookup(mockedPlexusContainer));

        assertEquals("clean", dl.getLifeCycles().get(0).getId());

        SuggestItem[] items = new SuggestItem[1];
        String[][] readings = new String[1][];
        readings[0] = new String[] { "test" };
        items[0] = new SuggestItem(new String[] { "test" }, readings, new String[] { "content" }, 0, 15, -1, new String[] { "tag1" },
                new String[] { SuggestConstants.DEFAULT_ROLE }, new String[] { "en" }, SuggestItem.Kind.QUERY);

##### COMPATIBLE_TLS versions

* **NEW:** TLSv1.3
* **NEW:** TLSv1.2
* **NEW:** TLSv1.1
* TLSv1

[OkHttp 3.12][OkHttp312]
------------------------

_2018-11-16_

Added support for TLSv1.3.

##### RESTRICTED_TLS cipher suites

 * **NEW:** TLS_AES_128_GCM_SHA256[¹][tlsv13_only]
 * **NEW:** TLS_AES_256_GCM_SHA384[¹][tlsv13_only]
 * **NEW:** TLS_CHACHA20_POLY1305_SHA256[¹][tlsv13_only]

            if (shouldThrowException) {
                throw new RuntimeException("Test exception in delayBeforeProcessing");
            }
        }

        @Override
        protected void delayAfterProcessing() {
            afterProcessingCount++;
            if (shouldThrowException) {
                throw new RuntimeException("Test exception in delayAfterProcessing");
            }
        }

        // Test in a different thread
        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicReference<String> otherThreadUrlQueueSessionId = new AtomicReference<>();
        final AtomicReference<String> otherThreadContextSessionId = new AtomicReference<>();

        Thread otherThread = new Thread(() -> {
            try {
                // Should be null in other thread (ThreadLocal isolation)

      invalidate(key);
    }
  }

  @Override
  public void invalidateAll() {
    throw new UnsupportedOperationException();
  }

  @Override
  public CacheStats stats() {
    throw new UnsupportedOperationException();
  }

  @Override
  public ConcurrentMap<K, V> asMap() {
    throw new UnsupportedOperationException();
  }

  /**

        @DisplayName("writeSetupWireFormat returns 0 for all indices")
        void writeSetupWireFormatReturnsZero(int index) {
            TransWaitNamedPipeResponse resp = new TransWaitNamedPipeResponse();
            assertEquals(0, resp.writeSetupWireFormat(new byte[10], index), "writeSetupWireFormat should always return 0");
        }

        @ParameterizedTest
        @ValueSource(ints = { 0, 5, -5, Integer.MAX_VALUE })