FuturesTransformTest extends AbstractChainedListenableFutureTest<String> { L31: private static final String RESULT_DATA = "SUCCESS"; L32: private static final UndeclaredThrowableException WRAPPED_EXCEPTION = L33: new UndeclaredThrowableException(EXCEPTION); L34: L35: @Override L36: protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { L37: return transform(inputFuture, new ComposeFunction(), directExecutor()); L38: } L39: L40: @Override L41: protected...

* Future} need not be {@linkplain Future#isDone done}, making {@code AsyncFunction} suitable for L35: * asynchronous derivations. L36: * L37: * <p>Throwing an exception from this method is equivalent to returning a failing {@code Future}. L38: */ L39: ListenableFuture<O> apply(@ParametricNullness I input) throws Exception; L40:}...

L35:import org.codelibs.fess.app.service.BadWordService; L36:import org.codelibs.fess.app.web.CrudMode; L37:import org.codelibs.fess.app.web.base.FessAdminAction; L38:import org.codelibs.fess.es.config.exentity.BadWord; L39:import org.codelibs.fess.exception.FessSystemException; L40:import org.codelibs.fess.helper.SuggestHelper; L41:import org.codelibs.fess.helper.SystemHelper; L42:import org.codelibs.fess.util.ComponentUtil; L43:import org.codelibs.fess.util.RenderDataUtil; L44:import org.dbflute.o...

L32: @Override L33: protected void setUp() throws Exception { L34: file1 = File.createTempFile("kuromoji_", ".txt"); L35: FileUtil.write( L36: file1.getAbsolutePath(), L37: "token1,seg1,reading1,pos1\ntoken2,seg2,reading2,pos2\ntoken3,seg3,reading3,pos3" L38: .getBytes(Constants.UTF_8)); L39: } L40: L41: @Override L42: protected void tearDown() throws Exception { L43: file1.delete(); L44: } L45: */ L46:...

Random(RANDOM_SEED).nextBytes(testBytes); L52: } L53: L54: // CRC32 L55: L56: @Benchmark L57: byte crc32HashFunction(int reps) { L58: return runHashFunction(reps, Hashing.crc32()); L59: } L60: L61: @Benchmark L62: byte crc32Checksum(int reps) throws Exception { L63: byte result = 0x01; L64: for (int i = 0; i < reps; i++) { L65: CRC32 checksum = new CRC32(); L66: checksum.update(testBytes, 0, testBytes.length); L67: result = (byte) (result ^ checksum.getValue()); L68: } L69: ...

ALLOWS_NULL_KEY_QUERIES) L70: public void testRemove_nullKeyQueriesUnsupported() { L71: try { L72: assertFalse(getMap().remove(null, v3())); L73: } catch (NullPointerException tolerated) { L74: // since the operation would be a no-op, the exception is not required L75: } L76: expectUnchanged(); L77: } L78: L79: @MapFeature.Require(value = SUPPORTS_REMOVE, absent = ALLOWS_NULL_VALUE_QUERIES) L80: public void testRemove_nullValueQueriesUnsupported() { L81: try { L82: assertF...

okhttp3.OkHttpClient; L21:import okhttp3.Request; L22:import okhttp3.RequestBody; L23:import okhttp3.Response; L24: L25:public final class PostForm { L26: private final OkHttpClient client = new OkHttpClient(); L27: L28: public void run() throws Exception { L29: RequestBody formBody = new FormBody.Builder() L30: .add("search", "Jurassic Park") L31: .build(); L32: Request request = new Request.Builder() L33: .url("https://en.wikipedia.org/w/index.php") L34: .post(formBody)...

org.codelibs.curl.Curl; L49:import org.codelibs.curl.CurlRequest; L50:import org.codelibs.curl.CurlResponse; L51:import org.codelibs.fess.crawler.Constants; L52:import org.codelibs.fess.exception.PluginException; L53:import org.codelibs.fess.util.ComponentUtil; L54:import org.codelibs.fess.util.ResourceUtil; L55:import org.lastaflute.di.exception.IORuntimeException; L56:import org.w3c.dom.Document; L57:import org.w3c.dom.Node; L58:import org.w3c.dom.NodeList; L59:import org.xml.sax.SAXException; L60: L61:import ...

return redirect(getClass()); // no-op L82: } L83: String line; L84: while ((line = ReaderUtil.readLine(reader)) != null) { L85: buf.append(line); L86: } L87: } catch (final Exception e) { L88: throwValidationError(messages -> messages.addErrorsFailedToReadRequestFile(GLOBAL, e.getMessage()), L89: () -> asListHtml(this::saveToken)); L90: } L91: L92: final CurlRequest curlRequest = g...

L74: }); L75: return null; L76: }); L77: try { L78: pathMappingService.store(entity); L79: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L80: } catch (final Exception e) { L81: logger.warn("Failed to process a request.", e); L82: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L83: } L84: return asJson(new...