private final ForwardingWrapperTester tester = new ForwardingWrapperTester();

  public void testGoodForwarder() {
    tester.testForwarding(
        Arithmetic.class,
        new Function<Arithmetic, Arithmetic>() {
          @Override
          public Arithmetic apply(Arithmetic arithmetic) {
            return new ForwardingArithmetic(arithmetic);
          }
        });
    tester.testForwarding(

        String s = new String(new char[] {randomLowSurrogate(random)});
        for (PrimitiveSink sink : sinks) {
          sink.putUnencodedChars(s);
        }
      }
    },
    PUT_STRING_HIGH_SURROGATE() {
      @Override
      void performAction(Random random, Iterable<? extends PrimitiveSink> sinks) {
        String s = new String(new char[] {randomHighSurrogate(random)});

    AbstractFuture<String> future = new AbstractFuture<String>() {};
    WaiterThread waiter = new WaiterThread(future);
    waiter.start();
    waiter.awaitWaiting();
    PollingThread poller = new PollingThread(future);
    poller.start();
    PollingThread poller2 = new PollingThread(future);
    poller2.start();
    PollingThread poller3 = new PollingThread(future);
    poller3.start();

            // Arrange
            rpc.uuid_t rpcUuid = new rpc.uuid_t();
            rpcUuid.time_low = 0;
            rpcUuid.time_mid = 0;
            rpcUuid.time_hi_and_version = 0;
            rpcUuid.clock_seq_hi_and_reserved = 0;
            rpcUuid.clock_seq_low = 0;
            rpcUuid.node = new byte[6];

            UUID uuid = new UUID(rpcUuid);

            // Act

        StringReader sReader = new StringReader(serializedModel);

        MavenStaxReader modelReader = new MavenStaxReader();
        try {
            model = new Model(modelReader.read(sReader));
        } catch (XMLStreamException e) {
            throw new ModelInterpolationException(

        final ByteArrayOutputStream baos = new ByteArrayOutputStream();
        try (final ZipOutputStream zos = new ZipOutputStream(baos)) {
            final ZipEntry entry = new ZipEntry("unknown.xyz");
            zos.putNextEntry(entry);
            zos.write("Some content".getBytes());
            zos.closeEntry();
        }

        final InputStream in = new ByteArrayInputStream(baos.toByteArray());

        querySecurityDesc = new NtTransQuerySecurityDesc(mockConfig, 0x1234, OWNER_SECURITY_INFORMATION);
        byte[] buffer = new byte[100];

        int result = querySecurityDesc.readParametersWireFormat(buffer, 10, 50);

        assertEquals(0, result);
    }

    @Test
    @DisplayName("Test readDataWireFormat returns zero")
    void testReadDataWireFormat() {

                new String[] { SuggestConstants.DEFAULT_ROLE }, null, SuggestItem.Kind.DOCUMENT);
        SuggestItem item3 = new SuggestItem(new String[] { "テスト" }, readings, new String[] { "content" }, 3, 0, -1, new String[] { "tag1" },
                new String[] { SuggestConstants.DEFAULT_ROLE }, null, SuggestItem.Kind.DOCUMENT);

    }

    @Test
    void testEquals() {
        SmbTree tree1 = new SmbTree(session, "testShare", "testService");
        SmbTree tree2 = new SmbTree(session, "testShare", "testService");
        SmbTree tree3 = new SmbTree(session, "otherShare", "testService");
        SmbTree tree4 = new SmbTree(session, "testShare", "otherService");

        // Test equal trees (same share and service)

            throw new IllegalArgumentException("failed to build synonyms", e);
        }
    }

    private Reader getReader(final boolean reload) throws IOException {
        if (reload) {
            if (reloadableFile == null) {
                throw new IllegalArgumentException("reloadableFile is null.");
            }