messages -> {}); L87: body.crudMode = CrudMode.CREATE; L88: final FileConfig fileConfig = getFileConfig(body).map(entity -> { L89: try { L90: fileConfigService.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...

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()...

return chain.proceed(chain.request()); L42: } L43: }; L44: L45: private final OkHttpClient client = new OkHttpClient.Builder() L46: .addNetworkInterceptor(CHECK_HANDSHAKE_INTERCEPTOR) L47: .build(); L48: L49: public void run() throws Exception { L50: Request request = new Request.Builder() L51: .url("https://publicobject.com/helloworld.txt") L52: .build(); L53: L54: try (Response response = client.newCall(request).execute()) { L55: if (!response.isSuccessful())...

L84: body.crudMode = CrudMode.CREATE; L85: final BoostDocumentRule boostDoc = getBoostDocumentRule(body).map(entity -> { L86: try { L87: boostDocumentRuleService.store(entity); L88: } catch (final Exception e) { L89: logger.warn("Failed to process a request.", e); L90: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L91: } L92: return...

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

final class PostStreaming { L27: public static final MediaType MEDIA_TYPE_MARKDOWN L28: = MediaType.get("text/x-markdown; charset=utf-8"); L29: L30: private final OkHttpClient client = new OkHttpClient(); L31: L32: public void run() throws Exception { L33: RequestBody requestBody = new RequestBody() { L34: @Override public MediaType contentType() { L35: return MEDIA_TYPE_MARKDOWN; L36: } L37: L38: @Override public void writeTo(BufferedSink sink) throws IOException {...

getDataConfig(form).ifPresent(entity -> { L234: try { L235: dataConfigService.store(entity); L236: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L237: } catch (final Exception e) { L238: logger.warn("Failed to process a request.", e); L239: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L240: this::asEditHtml);...

"e").inOrder(); L258: L259: subset.clear(); L260: assertThat(elementSet).containsExactly("a", "f").inOrder(); L261: assertThat(subset).isEmpty(); L262: assertEquals(3, ms.size()); L263: } L264: L265: public void testCustomComparator() throws Exception { L266: Comparator<String> comparator = L267: new Comparator<String>() { L268: @Override L269: public int compare(String o1, String o2) { L270: return o2.compareTo(o1); L271: } L272: }; L273:...

assertCastFails(long value) { L77: try { L78: UnsignedBytes.checkedCast(value); L79: fail("Cast to byte should have failed: " + value); L80: } catch (IllegalArgumentException ex) { L81: assertWithMessage(value + " not found in exception text: " + ex.getMessage()) L82: .that(ex.getMessage().contains(String.valueOf(value))) L83: .isTrue(); L84: } L85: } L86: L87: public void testCompare() { L88: // This is the only ordering for primitives that does not have...