ConcurrentModificationException.class,
        () -> {
          Iterator<E> iterator = collection.iterator();
          assertTrue(collection.add(e3()));
          iterator.next();
        });
  }

  /**
   * Returns the {@link Method} instance for {@link #testAdd_nullSupported()} so that tests of
   * {@link java.util.Collections#checkedCollection(java.util.Collection, Class)} can suppress it

    }
  }

  @Throws(FileNotFoundException::class)
  private fun newJournalWriter(): BufferedSink {
    val fileSink = fileSystem.appendingSink(journalFile)
    val faultHidingSink =
      FaultHidingSink(fileSink) {
        assertLockHeld()
        hasJournalErrors = true
      }
    return faultHidingSink.buffer()
  }

  @Throws(IOException::class)
  private fun readJournalLine(line: String) {

        options.numOfThreads = 1;
        options.cleanup = false;

        // Setup mock components
        setupMockComponents();

        Method processMethod = ThumbnailGenerator.class.getDeclaredMethod("process", ThumbnailGenerator.Options.class);
        processMethod.setAccessible(true);

        try {
            Integer result = (Integer) processMethod.invoke(null, options);
            assertNotNull(result);

    return callables;
  }

  private static final class WrappedCallable<T> implements Callable<T> {
    private final Callable<T> delegate;

    WrappedCallable(Callable<T> delegate) {
      this.delegate = delegate;
    }

    @Override
    public T call() throws Exception {
      return delegate.call();
    }
  }

  private static final class WrappedRunnable implements Runnable {

    /**
     * File end-of-file information class constant.
     */
    byte FILE_ENDOFFILE_INFO = 20;

    /**
     * File basic information class constant.
     */
    byte FILE_BASIC_INFO = 0x4;
    /**
     * File standard information class constant.
     */
    byte FILE_STANDARD_INFO = 0x5;

    /**
     * File internal information class constant.
     */
    byte FILE_INTERNAL_INFO = 0x6;

## Installazione

<div class="termy">

```console
$ pip install fastapi

---> 100%
```

</div>

   * }
   * if (failure != null) {
   *   throwIfInstanceOf(failure, BarException.class);
   *   throwIfUnchecked(failure);
   *   throw new AssertionError(failure);
   * }
   * </pre>
   *
   * @since 20.0
   */
  @GwtIncompatible // Class.cast, Class.isInstance
  public static <X extends Throwable> void throwIfInstanceOf(
      Throwable throwable, Class<X> declaredType) throws X {
    checkNotNull(throwable);

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package jcifs.dcerpc.ndr;

/**
 * Base class for NDR (Network Data Representation) objects used in DCE/RPC communication.
 * This abstract class defines the interface for encoding and decoding NDR data types.
 */
public abstract class NdrObject {

    /**
     * Default constructor for NDR object
     */
    public NdrObject() {

 */

package jcifs.smb1.dcerpc.ndr;

/**
 * Base class for NDR (Network Data Representation) objects used in DCE/RPC communication.
 * This abstract class defines the interface for encoding and decoding NDR data types.
 */
public abstract class NdrObject {

    /**
     * Default constructor for NDR object
     */
    public NdrObject() {

        NameServicePacket.writeInt2(NameServicePacket.IN, src, 12); // Mock class

        when(mockQuestionName.readWireFormat(any(byte[].class), anyInt())).thenReturn(10); // Mock name length

        int read = packet.readQuestionSectionWireFormat(src, 0);
        assertEquals(14, read); // 10 (name) + 2 (type) + 2 (class)
        verify(mockQuestionName).readWireFormat(src, 0);