Stosowanie listy funkcji do wartości ze strumieniem Java8 api

Question

Chcę wziąć jedną wiadomość dziennika pojo LoggedExchange i zastosować do niej kilka transformacji. Przemiany są UnaryOperators w formie listy:

List<ConditionalTransform> transforms = new ArrayList<>(); 

gdzie ConditionalTransform implementuje UnaryOperator<LoggedExchange> i moje obecne rozwiązanie jest przy użyciu zmniejszyć tak:

public LoggedExchange transform(LoggedExchange original) { 
    return transforms.stream().reduce(original, (o, t) -> t.apply(o), (m1, m2) -> m2); 
} 

Running to równolegle nie ma sensu, ponieważ nie ma sposobu aby połączyć dwa komunikaty ((m1,m2) -> m2 jest po to, aby kompilator był szczęśliwy).

Czy istnieje lepszy sposób to zrobić (jak w jakiś sposób komponowanie wszystkich ConditionalTranforms?), A jeśli nie, czy funkcja combiner wyrzucić wyjątek lub coś, ponieważ nie mogę obsługiwać wykonania równoległego?

Według instrukcji JavaDoc większość tych operacji powinna być możliwa dzięki map i reduce, ale nie rozumiem, w jaki sposób.

Answer 1

Coś jak to powinno działać:

public LoggedExchange transform(LoggedExchange original) { 
    return transforms.stream().reduce(UnaryOperator.identity(), (a, b) -> ((LoggedExchange o) -> b.apply(a.apply(o)))).apply(original); 
} 

ten konstruuje pojedynczego UnaryOperator<LoggedExchange> która dotyczy wszystkich funkcji w transforms z kolei wywołuje go z wartości wejściowej.

Ewentualnie zawsze jest prosta wersja pętli:

public LoggedExchange transform(LoggedExchange value) { 
    for(UnaryOperator<LoggedExchange> transform : transforms) 
     value = transform.apply(value); 
    return value; 
} 

Answer 2

Nie sądzę, jesteś naprawdę zmniejszenie czegokolwiek. Myślę, że zamiast tego po prostu odwzorowujesz ciąg w innym ciągu.

chciałbym napisać to:

trasforms 
    .forEach(transformation -> transformation.apply(original)); 

I pamiętać, aby zadeklarować oryginalny jako ostateczny.