Operations L50: L51: /** L52: * {@inheritDoc} L53: * L54: * @throws IllegalArgumentException if the given value is already bound to a different key in this L55: * bimap. The bimap will remain unmodified in this event. To avoid this exception, call {@link L56: * #forcePut} instead. L57: */ L58: @CanIgnoreReturnValue L59: @Override L60: @CheckForNull L61: V put(@ParametricNullness K key, @ParametricNullness V value); L62: L63: /** L64: * An alternate form of {@code put}...

* IllegalArgumentException} if passed a {@code fromElement} smaller than an earlier {@code L661: * fromElement}. However, this method doesn't throw an exception in that situation, but instead L662: * keeps the original {@code fromElement}. Similarly, this method keeps the original {@code L663: * toElement}, instead of throwing an exception, if passed a {@code toElement} greater than an L664: * earlier {@code toElement}. L665: */ L666: @Override L667: public ImmutableSortedSet<E> subSet(E...

getRelatedQuery(form).ifPresent(entity -> { L203: try { L204: relatedQueryService.store(entity); L205: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L206: } catch (final Exception e) { L207: logger.warn("Failed to process a request.", e); L208: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L209: this::asEditHtml);...

after close`() { L110: val deflater = MessageDeflater(true) L111: deflater.close() L112: L113: assertFailsWith<Exception> { L114: deflater.deflate("Hello deflate!".encodeUtf8()) L115: } L116: } L117: L118: @Test fun `inflate after close`() { L119: val inflater = MessageInflater(false) L120: L121: inflater.close() L122: L123: assertFailsWith<Exception> { L124: inflater.inflate("f240e30300".decodeHex()) L125: } L126: } L127: L128: /** L129: * Test for an [EOFException]...

org.lastaflute.web.response.HtmlResponse; L42:import org.lastaflute.web.response.render.RenderData; L43:import org.lastaflute.web.ruts.process.ActionRuntime; L44:import org.lastaflute.web.validation.VaErrorHook; L45:import org.lastaflute.web.validation.exception.ValidationErrorException; L46: L47:import jakarta.annotation.Resource; L48: L49:/** L50: * @author shinsuke L51: * @author Keiichi Watanabe L52: */ L53:public class AdminDictKuromojiAction extends FessAdminAction { L54: L55: public static final...

ClassLoaders? L39:@AndroidIncompatible L40:@GwtIncompatible L41:public class FinalizableReferenceQueueTest extends TestCase { L42: L43: private @Nullable FinalizableReferenceQueue frq; L44: L45: @Override L46: protected void tearDown() throws Exception { L47: frq = null; L48: } L49: L50: L51: public void testFinalizeReferentCalled() { L52: final MockReference reference = new MockReference(frq = new FinalizableReferenceQueue()); L53: L54: GcFinalization.awaitDone( L55: new GcF...

QueryBuilder queryBuilder = QueryBuilders.rangeQuery(fessConfig.getIndexFieldExpires()).to("now"); L38: try { L39: searchEngineClient.deleteByQuery(fessConfig.getIndexDocumentUpdateIndex(), queryBuilder); L40: L41: } catch (final Exception e) { L42: logger.error("Could not delete expired documents: {}", queryBuilder, e); L43: resultBuf.append(e.getMessage()).append("\n"); L44: } L45: L46: return resultBuf.toString(); L47: } L48: L49:}...

refers to. L36: */ L37:public final class PrintEventsNonConcurrent { L38: private final OkHttpClient client = new OkHttpClient.Builder() L39: .eventListener(new PrintingEventListener()) L40: .build(); L41: L42: public void run() throws Exception { L43: Request request = new Request.Builder() L44: .url("https://publicobject.com/helloworld.txt") L45: .build(); L46: L47: System.out.println("REQUEST 1 (new connection)"); L48: try (Response response = client.newCall(request).execute())...

L90: } L91: } L92: L93: /** Constructor for use by subclasses. */ L94: protected AbstractIdleService() {} L95: L96: /** Start the service. */ L97: protected abstract void startUp() throws Exception; L98: L99: /** Stop the service. */ L100: protected abstract void shutDown() throws Exception; L101: L102: /** L103: * Returns the {@link Executor} that will be used to run this service. Subclasses may override L104: * this method to use a custom {@link Executor}, which may configure its...

getFileAuthentication(form).ifPresent(entity -> { L203: try { L204: fileAuthenticationService.store(entity); L205: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L206: } catch (final Exception e) { L207: logger.warn("Failed to process a request.", e); L208: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L209: this::asEditHtml);...