class AggregateRequestBodyExamplePlugin implements Plugin {

    @Override
    public Eventual<LiveHttpResponse> intercept(LiveHttpRequest request, Chain chain) {

       return request.aggregate(10000)
                .map(fullRequest -> {
                    String body = fullRequest.bodyAs(UTF_8);
                    return fullRequest.newBuilder()
                            .body(body + config.extraText(), UTF_8)
                            .build().stream();
                }).flatMap(chain::proceed);
    }

    public  AggregateRequestBodyExamplePlugin(Config config);

}