java.io.IOException; L19:import okhttp3.OkHttpClient; L20:import okhttp3.Request; L21:import okhttp3.Response; L22: L23:public final class AccessHeaders { L24: private final OkHttpClient client = new OkHttpClient(); L25: L26: public void run() throws Exception { L27: Request request = new Request.Builder() L28: .url("https://api.github.com/repos/square/okhttp/issues") L29: .header("User-Agent", "OkHttp Headers.java") L30: .addHeader("Accept", "application/json; q=0.5") L31: ...

L61:import org.codelibs.fess.entity.QueryContext; L62:import org.codelibs.fess.entity.SearchRequestParams.SearchRequestType; L63:import org.codelibs.fess.exception.FessSystemException; L64:import org.codelibs.fess.exception.InvalidQueryException; L65:import org.codelibs.fess.exception.ResultOffsetExceededException; L66:import org.codelibs.fess.exception.SearchQueryException; L67:import org.codelibs.fess.helper.DocumentHelper; L68:import org.codelibs.fess.helper.QueryHelper; L69:import org.codelibs.fe...

L28: L29:/** L30: * Unit test for {@link AbstractLoadingCache}. L31: * L32: * @author Charles Fry L33: */ L34:public class AbstractLoadingCacheTest extends TestCase { L35: L36: public void testGetUnchecked_checked() { L37: final Exception cause = new Exception(); L38: final AtomicReference<Object> valueRef = new AtomicReference<>(); L39: LoadingCache<Object, Object> cache = L40: new AbstractLoadingCache<Object, Object>() { L41: @Override L42: public Object get(Object...

= getFessConfig().getCrawlerDocumentSiteEncoding(); L94: } else { L95: enc = encoding; L96: } L97: L98: try { L99: url = URLDecoder.decode(url, enc); L100: } catch (final Exception e) {} L101: } L102: L103: return abbreviateSite(url); L104: } L105: L106: default void putResultDataBody(final Map<String, Object> dataMap, final String key, final Object value) { L107: final FessConfig fessConfig = Co...

); L35: } L36: L37: public void testSuccessfulNull() throws ExecutionException { L38: assertThat(getDone(Futures.<@Nullable String>immediateFuture(null))).isEqualTo(null); L39: } L40: L41: public void testFailed() { L42: Exception failureCause = new Exception(); L43: ExecutionException expected = L44: assertThrows(ExecutionException.class, () -> getDone(immediateFailedFuture(failureCause))); L45: assertThat(expected).hasCauseThat().isEqualTo(failureCause); L46: } L47: L48:...

L257: try { L258: pendingDescription = pendingToString(); L259: } catch (RuntimeException e) { L260: // Don't call getMessage or toString() on the exception, in case the exception thrown by the L261: // subclass is implemented with bugs similar to the subclass. L262: pendingDescription = "Exception thrown from implementation: " + e.getClass(); L263: } L264: // The future may complete during or before the call to getPendingToString, so we use null L265:...

okhttp3.OkHttpClient; L23:import okhttp3.Request; L24:import okhttp3.Response; L25:import okhttp3.ResponseBody; L26: L27:public final class AsynchronousGet { L28: private final OkHttpClient client = new OkHttpClient(); L29: L30: public void run() throws Exception { L31: Request request = new Request.Builder() L32: .url("http://publicobject.com/helloworld.txt") L33: .build(); L34: L35: client.newCall(request).enqueue(new Callback() { L36: @Override public void onFailure(Call call,...

{ L27: private final OkHttpClient client = new OkHttpClient(); L28: private final Moshi moshi = new Moshi.Builder().build(); L29: private final JsonAdapter<Gist> gistJsonAdapter = moshi.adapter(Gist.class); L30: L31: public void run() throws Exception { L32: Request request = new Request.Builder() L33: .url("https://api.github.com/gists/c2a7c39532239ff261be") L34: .build(); L35: try (Response response = client.newCall(request).execute()) { L36: if (!response.isSuccessful())...

L23:import java.net.URL; L24:import java.net.URLClassLoader; L25: L26:import org.junit.Test; L27: L28:/** L29: * @author koichik L30: */ L31:public class ClassLoaderIteratorTest { L32: L33: /** L34: * @throws Exception L35: */ L36: @Test L37: public void test() throws Exception { L38: final ClassLoader cl1 = new URLClassLoader(new URL[] { new URL("file:/foo") }, null); L39: final ClassLoader cl2 = new URLClassLoader(new URL[] { new URL("file:/bar") }, cl1); L40: final...

be called on the {@link Listener}. L283: * L284: * @param from The previous state that is being transitioned from. Failure can occur in any L285: * state with the exception of {@linkplain State#NEW NEW} or {@linkplain State#TERMINATED L286: * TERMINATED}. L287: * @param failure The exception that caused the failure. L288: */ L289: public void failed(State from, Throwable failure) {} L290: } L291:}...