gistfile1.txt

private Function<String, Mono<? extends Orders>> keyToOrder(RedisReactiveCommands<String, String> commands) {
    return { key -> 
        Flux<KeyValue<String, String>> values = commands.hmget(key, "price", "description")
        Map map = [:]
        return values.reduce(map, (all, keyValue)= {all.put(keyValue.getKey(), keyValue.getValue())
            return all
        }).map({entries -> ConvertibleValues.of(entries)})
                .flatMap({entries -> 
            String description = entries.get("description", String.class).orElseThrow({ new IllegalStateException("No description")})
            BigDecimal price = entries.get("price", BigDecimal.class).orElseThrow({new IllegalStateException("No price")})
            Flowable<Item> findItemFlowable = itemClient.find(key).toFlowable()
            return Mono.from(findItemFlowable).map({item -> new Orders(item, description, price)})
        });
    }
}