H subscriber; L39: L40: H getSubscriber() { L41: return subscriber; L42: } L43: L44: @Override L45: protected void setUp() throws Exception { L46: subscriber = createSubscriber(); L47: EventBus bus = new EventBus(); L48: bus.register(subscriber); L49: bus.post(EVENT); L50: } L51: L52: @Override L53: protected void tearDown() throws Exception { L54: subscriber = null; L55: } L56:}...

okhttp3.Response; L25: L26:public final class CurrentDateHeader { L27: private final OkHttpClient client = new OkHttpClient.Builder() L28: .addInterceptor(new CurrentDateInterceptor()) L29: .build(); L30: L31: public void run() throws Exception { L32: Request request = new Request.Builder() L33: .url("https://publicobject.com/helloworld.txt") L34: .build(); L35: L36: try (Response response = client.newCall(request).execute()) { L37: System.out.println(response....

final class PostString { L26: public static final MediaType MEDIA_TYPE_MARKDOWN L27: = MediaType.get("text/x-markdown; charset=utf-8"); L28: L29: private final OkHttpClient client = new OkHttpClient(); L30: L31: public void run() throws Exception { L32: String postBody = "" L33: + "Releases\n" L34: + "--------\n" L35: + "\n" L36: + " * _1.0_ May 6, 2013\n" L37: + " * _1.1_ June 15, 2013\n" L38: + " * _1.2_ August 11, 2013\n"; L39: L40: Request...

L25:import junit.framework.TestCase; L26: L27:/** L28: * Unit test for {@link TypeParameter}. L29: * L30: * @author Ben Yu L31: */ L32:public class TypeParameterTest extends TestCase { L33: L34: public <T> void testCaptureTypeParameter() throws Exception { L35: TypeVariable<?> variable = new TypeParameter<T>() {}.typeVariable; L36: TypeVariable<?> expected = L37: TypeParameterTest.class.getDeclaredMethod("testCaptureTypeParameter") L38: .getTypeParameters()[0]; L39: as...

final AccessToken accessToken = getAccessToken(body).map(entity -> { L85: entity.setToken(accessTokenHelper.generateAccessToken()); L86: try { L87: accessTokenService.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...

} L89: L90: body.crudMode = CrudMode.CREATE; L91: final RequestHeader reqHeader = getRequestHeader(body).map(entity -> { L92: try { L93: reqHeaderService.store(entity); L94: } catch (final Exception e) { L95: logger.warn("Failed to process a request.", e); L96: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L97: } L98: return...

} L89: L90: body.crudMode = CrudMode.CREATE; L91: final WebAuthentication webAuth = getWebAuthentication(body).map(entity -> { L92: try { L93: webAuthService.store(entity); L94: } catch (final Exception e) { L95: logger.warn("Failed to process a request.", e); L96: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L97: } L98: return...

return redirect(getClass()); // no-op L82: } L83: String line; L84: while ((line = ReaderUtil.readLine(reader)) != null) { L85: buf.append(line); L86: } L87: } catch (final Exception e) { L88: throwValidationError(messages -> messages.addErrorsFailedToReadRequestFile(GLOBAL, e.getMessage()), L89: () -> asListHtml(this::saveToken)); L90: } L91: L92: final CurlRequest curlRequest = g...

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

L80: body.crudMode = CrudMode.CREATE; L81: final RelatedContent relatedContent = getRelatedContent(body).map(entity -> { L82: try { L83: relatedContentService.store(entity); L84: } catch (final Exception e) { L85: logger.warn("Failed to process a request.", e); L86: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e))); L87: } L88: return...