L25:import okhttp3.Response; L26: L27:public class CancelCall { L28: private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(1); L29: private final OkHttpClient client = new OkHttpClient(); L30: L31: public void run() throws Exception { L32: Request request = new Request.Builder() L33: .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. L34: .build(); L35: L36: final long startNanos = System.nanoTime(); L37: final Call call =...

L35: */ L36:public class SAXParserFactoryUtilTest extends TestCase { L37: L38: boolean included; L39: L40: /** L41: * {@link SAXParserFactoryUtil#setXIncludeAware}のテストです。 L42: * L43: * @throws Exception L44: */ L45: public void testSetXIncludeAware() throws Exception { L46: final SAXParserFactory spf = SAXParserFactoryUtil.newInstance(); L47: SAXParserFactoryUtil.setXIncludeAware(spf, true); L48: spf.setNamespaceAware(true); L49: final SAXParser...

CONDITIONS OF ANY KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.es.client; L17: L18:import org.codelibs.fess.exception.FessSystemException; L19: L20:public class SearchEngineClientException extends FessSystemException { L21: L22: private static final long serialVersionUID = 1L; L23: L24: public SearchEngineClientException(final String message, final Throwable...

validateApi(body, messages -> {}); L87: body.crudMode = CrudMode.CREATE; L88: final LabelType labelType = getLabelType(body).map(entity -> { L89: try { L90: labelTypeService.store(entity); L91: } catch (final Exception e) { L92: logger.warn("Failed to process a request.", e); L93: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L94: } L95: return...

@AndroidIncompatible // no FpUtils and no Math.nextDown in old versions L36: public void testNextDown() throws Exception { L37: Method jdkNextDown = getJdkNextDown(); L38: for (double d : FINITE_DOUBLE_CANDIDATES) { L39: assertEquals(jdkNextDown.invoke(null, d), DoubleUtils.nextDown(d)); L40: } L41: } L42: L43: private static Method getJdkNextDown() throws Exception { L44: try { L45: return Math.class.getMethod("nextDown", double.class); L46: } catch (NoSuchMethodException...

IMMUTABLE_NETWORK_B); L63: setDefault(EndpointPair.class, EndpointPair.ordered("A", "B")); L64: } L65: L66: @Override L67: public void testNulls() throws Exception { L68: try { L69: super.testNulls(); L70: } catch (AssertionError e) { L71: assertWithMessage("Method did not throw null pointer OR element not in graph exception.") L72: .that(e) L73: .hasCauseThat() L74: .hasMessageThat() L75: .contains(ERROR_ELEMENT_NOT_IN_GRAPH); L76: } L77:...

java.util.concurrent.Executors L27:import okhttp3.AsyncDns L28:import okhttp3.ExperimentalOkHttpApi L29: L30:/** L31: * DNS implementation based on android.net.DnsResolver, which submits a request for L32: * A or AAAA records, and returns the addresses or exception. L33: * L34: * Two instances must be used to get all results for an address. L35: * L36: * @param network network to use, if not selects the default network. L37: */ L38:@RequiresApi(Build.VERSION_CODES.Q) L39:@ExperimentalOkHttpApi L40:class AndroidAsyncDns(...

L19:import assertk.assertions.isEqualTo L20:import assertk.assertions.isFalse L21:import assertk.assertions.isTrue L22:import kotlin.test.Test L23:import kotlin.time.Duration.Companion.seconds L24: L25:class CacheControlTest { L26: @Test L27: @Throws(Exception::class) L28: fun emptyBuilderIsEmpty() { L29: val cacheControl = CacheControl.Builder().build() L30: assertThat(cacheControl.toString()).isEqualTo("") L31: assertThat(cacheControl.noCache).isFalse() L32: assertThat(cacheControl.noStore).isFalse()...

; L216: getUser(form).ifPresent(entity -> { L217: try { L218: userService.store(entity); L219: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L220: } catch (final Exception e) { L221: logger.warn("Failed to add {}", entity, e); L222: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L223: this::asEditHtml);...

"AS IS" BASIS, L12: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.exception; L17: L18:public class FessSystemException extends RuntimeException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: public FessSystemException(final String message, final Throwable cause) { L23: super(message,...