// Теоретический пример: строковое декодирование
Flux<DataBuffer> bodyFlux = exchange.getRequest().getBody();
Mono<String> bodyString = DataBufferUtils.join(bodyFlux, maxInMemorySize)
    .map(buffer -> {
        byte[] bytes = new byte[buffer.readableByteCount()];
        buffer.read(bytes);
        DataBufferUtils.release(buffer);
        return new String(bytes, StandardCharsets.UTF_8);
    });

// Теоретический пример: трансформация через JsonNode
Function<JsonNode, JsonNode> transformer = root -> {
    // Модификация дерева
    if (root.has("user")) {
        ((ObjectNode) root.get("user")).put("processedBy", "gateway");
    }
    return root;
};

// Теоретический пример: добавление поля в ответ
Function<String, String> responseTransformer = originalJson -> {
    // Парсинг JSON, добавление поля, сериализация обратно
    JsonNode root = objectMapper.readTree(originalJson);
    ((ObjectNode) root).put("gatewayProcessed", true);
    return objectMapper.writeValueAsString(root);
};

{
  "data": { /* оригинальный ответ */ },
  "metadata": { "processedBy": "gateway", "timestamp": "..." }
}

import java.util.*;
import java.util.stream.*;

public class Task231225 {
    public static void main(String[] args) {
        LinkedList<Integer> list = new LinkedList<>();
        list.add(1);
        list.add(2);
        list.add(3);
        
        Stream<Integer> stream = list.stream();
        list.add(4);
        
        System.out.println(stream.count());
    }
}