本文整理了Java中io.gravitee.gateway.api.handler.Handler类的一些代码示例，展示了Handler类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Handler类的具体详情如下：
包路径：io.gravitee.gateway.api.handler.Handler
类名称：Handler

Handler介绍

[英]A generic event handler
[中]通用事件处理程序

代码示例

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public ReadStream<Buffer> resume() {
    endHandler.handle(null);
    return this;
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public void handle(ProcessorFailure failure) {
    errorHandler.handle(failure);
  }
})

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public void doNext(Request request, Response response) {
  resultHandler.handle(SUCCESS_POLICY_CHAIN);
}

代码示例来源：origin: gravitee-io/gravitee-gateway

void sendResponse() {
    this.responseHandler.handle(proxyResponse);
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

public void handleResponse(ProxyResponse proxyResponse) {
  transmitted = true;
  this.responseHandler.handle(proxyResponse);
}

代码示例来源：origin: gravitee-io/gravitee-gateway

public void handleConnectTimeout(Throwable throwable) {
  this.timeoutHandler.handle(throwable);
}

代码示例来源：origin: gravitee-io/gravitee-gateway

public void sendResponse() {
  this.responseHandler.handle(response);
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public ReadStream<Buffer> resume() {
    if (! resumed) {
      request.resume();
      resumed = true;
    } else {
      if (bodyHandler != null && buffer != null) {
        bodyHandler.handle(buffer);
      }
      endHandler.handle(null);
    }

    return this;
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public StreamablePolicyChain write(Buffer chunk) {
  if (streamablePolicyHandlerChain != null) {
    streamablePolicyHandlerChain.write(chunk);
  } else {
    this.bodyHandler.handle(chunk);
  }
  return this;
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public void doNext(Request request, Response response) {
    if (policyResult.isFailure()) {
      errorHandler.handle(new PolicyChainProcessorFailure(policyResult));
    } else {
      resultHandler.handle(policyResult);
    }
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public ReadStream<Buffer> resume() {
    if (httpClientResponse != null) {
      httpClientResponse.resume();
    } else {
      endHandler.handle(null);
    }
    return null;
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public WriteStream<Buffer> drainHandler(Handler<Void> drainHandler) {
  httpClientRequest.drainHandler(aVoid -> drainHandler.handle(null));
  return this;
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public WriteStream<Buffer> drainHandler(Handler<Void> drainHandler) {
  httpServerResponse.drainHandler((aVoid -> drainHandler.handle(null)));
  return this;
}

代码示例来源：origin: gravitee-io/gravitee-gateway

private void sendBadGatewayResponse() {
    FailoverClientResponse response = new FailoverClientResponse();
    this.responseHandler.handle(response);
    response.endHandler().handle(null);
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public StreamableProcessor<PolicyResult> streamErrorHandler(Handler<ProcessorFailure> handler) {
  super.streamErrorHandler(processorFailure -> {
    streamErrorHandle = true;
    handler.handle(processorFailure);
  });
  return this;
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public void handle(ProxyResponse proxyResponse) {
    responseHandler.handle(new LoggableProxyConnection.LoggableProxyResponse(proxyResponse));
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public void end() {
  if (!streamErrorHandle) {
    if (streamablePolicyHandlerChain != null) {
      streamablePolicyHandlerChain.end();
    } else if (endHandler != null) {
      this.endHandler.handle(null);
    }
  }
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public void streamFailWith(PolicyResult policyResult) {
  streamErrorHandler.handle(new PolicyChainProcessorFailure(policyResult));
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
public void failWith(PolicyResult policyResult) {
  errorHandler.handle(new PolicyChainProcessorFailure(policyResult));
}

代码示例来源：origin: gravitee-io/gravitee-gateway

@Override
  public void handle(Response result) {
    String path = request.pathInfo();
    if (path.length() == 0 || path.charAt(path.length() - 1) != '/') {
      path += '/';
    }

    String finalPath = path;
    mapping.entrySet().stream()
        .filter(regexMappedPath -> regexMappedPath.getValue().matcher(finalPath).matches())
        .map(Map.Entry::getKey)
        .findFirst()
        .ifPresent(resolvedMappedPath -> request.metrics().setMappedPath(resolvedMappedPath));

    next.handle(result);
  }
}