make it explicit that the method L590: * will throw an exception if there are duplicate keys. The {@code build()} method will soon be L591: * deprecated. L592: * L593: * @throws IllegalArgumentException if duplicate keys were added L594: */ L595: public ImmutableMap<K, V> build() { L596: return buildOrThrow(); L597: } L598: L599: /** L600: * Returns a newly-created immutable map, or throws an exception if any key was added more than L601: * once. The iteration...

SID sid) { L61: final int type = sid.getType(); L62: if (logger.isDebugEnabled()) { L63: try { L64: logger.debug("Processing SID: {} {} {}", type, sid, sid.toDisplayString()); L65: } catch (final Exception e) { L66: // ignore L67: } L68: } L69: final Integer id = fessConfig.getAvailableSmbSidType(type); L70: if (id != null) { L71: return createSearchRole(id, sid.getAccountName()); L72: ...

extends CurlRequest { L43: L44: MockCurlRequest(Curl.Method method, String url) { L45: super(method, url); L46: } L47: L48: @Override L49: public void connect(Consumer<HttpURLConnection> actionListener, Consumer<Exception> exceptionListener) { L50: try { L51: actionListener.accept(new MockHttpURLConnection(new URL(url))); L52: } catch (MalformedURLException e) { L53: exceptionListener.accept(e); L54: }...

class PostStreamingWithPipe { L29: public static final MediaType MEDIA_TYPE_MARKDOWN L30: = MediaType.get("text/x-markdown; charset=utf-8"); L31: L32: private final OkHttpClient client = new OkHttpClient(); L33: L34: public void run() throws Exception { L35: final PipeBody pipeBody = new PipeBody(); L36: L37: Request request = new Request.Builder() L38: .url("https://api.github.com/markdown/raw") L39: .post(pipeBody) L40: .build(); L41: L42: streamPrimesToSinkAsy...

return builder.setScript(script); L63: } L64: } catch (final Exception e) { L65: logger.warn("Failed to process {}", hit, e); L66: } L67: return null; L68: }); L69: resultBuf.append(count).append(" docs").append("\n"); L70: } catch (final Exception e) { L71: logger.error("Could not update labels.", e); L72: resultBuf.append(e.getMessage()).append("\n");...

@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:...

true; L490: return "A message"; L491: } L492: } L493: L494: private static final String FORMAT = "I ate %s pies."; L495: L496: private static void verifySimpleMessage(Exception e) { L497: assertThat(e).hasMessageThat().isEqualTo("A message"); L498: } L499: L500: private static void verifyComplexMessage(Exception e) { L501: assertThat(e).hasMessageThat().isEqualTo("I ate 5 pies."); L502: } L503:}...

L75: val testClass = access.findClassByName(it) L76: L77: if (testClass != null) { L78: access.registerAsUsed(testClass) L79: registerTest(access, testClass) L80: } L81: } catch (e: Exception) { L82: // If you throw an exception here then native image building fails half way through L83: // silently without rewriting the binary. So we report noisily, but keep going and prefer L84: // running most tests still. L85: e.printStackTrace()...

okhttp3.Response; L23:import okhttp3.ResponseBody; L24:import okio.Buffer; L25:import okio.BufferedSource; L26:import okio.ForwardingSource; L27:import okio.Okio; L28:import okio.Source; L29: L30:public final class Progress { L31: L32: public void run() throws Exception { L33: Request request = new Request.Builder() L34: .url("https://publicobject.com/helloworld.txt") L35: .build(); L36: L37: final ProgressListener progressListener = new ProgressListener() { L38: boolean firstUpdate = true;...