the first invocation of {@code hasNext} or {@code next} following each successful call to L95: * {@code next}. Once the implementation either invokes {@code endOfData} or throws an exception, L96: * {@code computeNext} is guaranteed to never be called again. L97: * L98: * <p>If this method throws an exception, it will propagate outward to the {@code hasNext} or L99: * {@code next} invocation that invoked this method. Any further attempts to use the iterator will L100: * result in an {@link...

Credentials.basic("jesse", "password1"); L37: return response.request().newBuilder() L38: .header("Authorization", credential) L39: .build(); L40: }) L41: .build(); L42: } L43: L44: public void run() throws Exception { L45: Request request = new Request.Builder() L46: .url("http://publicobject.com/secrets/hellosecret.txt") L47: .build(); L48: L49: try (Response response = client.newCall(request).execute()) { L50: if (!response.isSuccessful())...

L25:import okhttp3.tls.HandshakeCertificates; L26:import okhttp3.tls.HeldCertificate; L27: L28:/** L29: * Create an HTTPS server with a self-signed certificate that OkHttp trusts. L30: */ L31:public class HttpsServer { L32: public void run() throws Exception { L33: HeldCertificate localhostCertificate = new HeldCertificate.Builder() L34: .addSubjectAlternativeName("localhost") L35: .build(); L36: L37: HandshakeCertificates serverCertificates = new HandshakeCertificates.Builder() L38:...

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.util; L17: L18:import org.codelibs.fess.exception.WebApiException; L19:import org.lastaflute.web.util.LaRequestUtil; L20: L21:public final class WebApiUtil { L22: L23: private static final String WEB_API_EXCEPTION = "webApiException"; L24: L25: private WebApiUtil() { L26: } L27: L28: ...

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 =...

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

.TimeUnit; L20:import okhttp3.OkHttpClient; L21:import okhttp3.Request; L22:import okhttp3.Response; L23: L24:public final class PerCallSettings { L25: private final OkHttpClient client = new OkHttpClient(); L26: L27: public void run() throws Exception { L28: Request request = new Request.Builder() L29: .url("http://httpbin.org/delay/1") // This URL is served with a 1 second delay. L30: .build(); L31: L32: // Copy to customize OkHttp for this request. L33: OkHttpClient client1...

public PreemptiveAuth() { L29: client = new OkHttpClient.Builder() L30: .addInterceptor( L31: new BasicAuthInterceptor("publicobject.com", "jesse", "password1")) L32: .build(); L33: } L34: L35: public void run() throws Exception { L36: Request request = new Request.Builder() L37: .url("https://publicobject.com/secrets/hellosecret.txt") L38: .build(); L39: L40: try (Response response = client.newCall(request).execute()) { L41: if (!response.isSuccessful())...

License. L15: */ L16:package org.codelibs.fess.script.groovy; L17: L18:import java.util.HashMap; L19:import java.util.Map; L20: L21:import org.apache.logging.log4j.LogManager; L22:import org.apache.logging.log4j.Logger; L23:import org.codelibs.fess.exception.JobProcessingException; L24:import org.codelibs.fess.script.AbstractScriptEngine; L25:import org.lastaflute.di.core.factory.SingletonLaContainerFactory; L26: L27:import groovy.lang.Binding; L28:import groovy.lang.GroovyClassLoader; L29:import gr...

getScheduledJob(form).ifPresent(entity -> { L228: try { L229: scheduledJobService.store(entity); L230: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L231: } catch (final Exception e) { L232: logger.warn("Failed to process a request.", e); L233: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L234: this::asEditHtml);...