class ModifyContentByAggregationExamplePlugin implements Plugin {

    @Override
    public Eventual<LiveHttpResponse> intercept(LiveHttpRequest request, Chain chain) {
        return chain.proceed(request)
                .flatMap(response -> response.aggregate(10000))
                .map(response -> {
                    String body = response.bodyAs(UTF_8);
                    return response.newBuilder()
                            .body(body + config.extraText(), UTF_8)
                            .build();
                })
                .map(HttpResponse::stream);
    }

    public  ModifyContentByAggregationExamplePlugin(Config config);

}