Package ratpack.exec.internal

Examples of ratpack.exec.internal.DefaultExecController$ExecControllerBindingThreadFactory


    this.indexFiles = indexFiles;
    this.other = other;
    this.handlerFactory = handlerFactory;
    this.sslContext = sslContext;
    this.maxContentLength = maxContentLength;
    this.execController = new DefaultExecController(this.threads);
    this.defaultRegistry = defaultRegistry;
  }
View Full Code Here


import java.util.concurrent.TimeUnit;

public class BlockingHttpClient {

  public ReceivedResponse request(URI uri, long timeout, TimeUnit timeUnit, Action<? super RequestSpec> action) throws Throwable {
    try (ExecController execController = new DefaultExecController(2)) {
      final RequestAction requestAction = new RequestAction(uri, execController, action);

      execController.getControl().exec()
        .onError(throwable -> requestAction.setResult(Result.<ReceivedResponse>failure(throwable)))
        .start(requestAction::execute);

      try {
        // TODO - make this configurable
View Full Code Here

   * See the {@code ratpack.rx.RxRatpack.asPromise(Observable)} documentation for an example of testing observables.
   *
   * @return a new execution harness
   */
  public static ExecHarness harness() {
    return new DefaultExecHarness(new DefaultExecController());
  }
View Full Code Here

TOP

Related Classes of ratpack.exec.internal.DefaultExecController$ExecControllerBindingThreadFactory

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.