private void doPostFilter()

in runner-core/src/main/java/org/apache/apisix/plugin/runner/handler/RpcCallHandler.java [199:224]

23 lines of code
2 McCabe index (conditional complexity)


    private void doPostFilter(ChannelHandlerContext ctx) {
        A6Conf conf = cache.getIfPresent(confToken);
        if (Objects.isNull(conf)) {
            logger.warn("cannot find conf token: {}", confToken);
            errorHandle(ctx, Code.CONF_TOKEN_NOT_FOUND);
            return;
        }

        postReq.initCtx(conf.getConfig());
        postReq.setVars(nginxVars);

        PluginFilterChain chain = conf.getChain()
            .addFilter(new PluginFilter() {
                @Override
                public String name() {
                    return null;
                }

                @Override
                public void postFilter(PostRequest request, PostResponse response, PluginFilterChain chain) {
                    ChannelFuture future = ctx.writeAndFlush(postResp);
                    future.addListeners(ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE);
                }
            });
        chain.postFilter(postReq, postResp);
    }