Closer closer = Closer.create();
    try {
      BufferedReader reader = closer.register(openBufferedStream());
      List<String> result = new ArrayList<>();
      String line;
      while ((line = reader.readLine()) != null) {
        result.add(line);
      }
      return ImmutableList.copyOf(result);
    } catch (Throwable e) {
      throw closer.rethrow(e);
    } finally {
      closer.close();
    }
  }

    return delegate().submit(task);
  }

  @Override
  public <T extends @Nullable Object> ListenableFuture<T> submit(
      Runnable task, @ParametricNullness T result) {
    return delegate().submit(task, result);
  }

public class MavenParser extends BaseParser {
    @Override
    protected Options parseCliOptions(LocalContext context) {
        ArrayList<MavenOptions> result = new ArrayList<>();
        // CLI args
        MavenOptions cliOptions = parseMavenCliOptions(context.parserRequest.args());
        result.add(cliOptions);
        // atFile option
        if (cliOptions.atFile().isPresent()) {

        final int tmp = questionName.hexCode;
        questionName.hexCode = 0x00; // type has to be 0x00 for node status
        final int result = writeQuestionSectionWireFormat(dst, dstIndex);
        questionName.hexCode = tmp;
        return result;
    }

    @Override
    int readBodyWireFormat(final byte[] src, final int srcIndex) {
        return 0;
    }

    @Override

          else -> 0L
        }
      result =
        TriggerSink(
          delegate = result,
          triggerByteCount = halfwayByteCount,
        ) {
          result.flush()
          handleSocketEffect(socketEffect, socket, stream)
        }
    }

    return result
  }

  /** Returns true if processing this exchange is complete. */

                throw new RuntimeException("Simulated failure #" + count);
            }
            return "Success";
        });

        final String result = fesenClient.get(c -> mockFuture);

        assertEquals("Success", result);
        assertEquals(6, attemptCount.get()); // Initial attempt + 5 retries
    }

    /**
     * Test: Retry logic fails after exceeding maxRetryCount

  public static <K, V> ConcurrentMapTestSuiteBuilder<K, V> using(TestMapGenerator<K, V> generator) {
    ConcurrentMapTestSuiteBuilder<K, V> result = new ConcurrentMapTestSuiteBuilder<>();
    result.usingGenerator(generator);
    return result;
  }

  @SuppressWarnings("rawtypes") // class literals
  static final List<? extends Class<? extends AbstractTester>> TESTERS =
      asList(

  public static <K, V> ConcurrentMapTestSuiteBuilder<K, V> using(TestMapGenerator<K, V> generator) {
    ConcurrentMapTestSuiteBuilder<K, V> result = new ConcurrentMapTestSuiteBuilder<>();
    result.usingGenerator(generator);
    return result;
  }

  @SuppressWarnings("rawtypes") // class literals
  static final List<? extends Class<? extends AbstractTester>> TESTERS =
      asList(

            return toolchains;
        }

        PersistedToolchains result;
        try {
            Map<String, ?> options = Collections.singletonMap(ToolchainsReader.IS_STRICT, Boolean.FALSE);

            result = toolchainsReader.read(new StringReader(serializedToolchains), options);
        } catch (IOException e) {

    public void test_addErrorsOperationAlreadyRunning() {
        final FessMessages messages = new FessMessages();
        final FessMessages result = messages.addErrorsOperationAlreadyRunning("testProperty", "host1");
        assertNotNull(result);
        assertFalse(result.isEmpty());
        assertTrue(result.hasMessageOf("testProperty"));
    }

    @Test
    public void test_addErrorsOperationAlreadyRunning_withDifferentHosts() {