Nie można zrozumieć Iteratee, Enumerator, Enumeratee w Play 2.0

Question

Właśnie zacząłem uczyć się gry w wersji 2.0 Framework. Jedyne, czego nie mogę zrozumieć, to wzór Iteratee, Enumerator i Enumeratee opisany w play tutorial. Mam bardzo małe doświadczenie w językach funkcjonalnych.

Co osiąga ten wzór?

W jaki sposób pomaga mi pisać kod nieblokujący/reaktywny?

pomocne mogą być niektóre proste przykłady.

Answer 1

Pobieranie playframework 2.0 zawiera kilka próbek. Dwa z nich mają przykłady Iteratee/Comet. Na przykład kometa zegar sample app pokazuje:

lazy val clock = Enumerator.fromCallback {() => 
    Promise.timeout(Some(dateFormat.format(new Date)), 100 milliseconds) 
} 

Następnie stosuje się go tak:

Ok.stream(clock &> Comet(callback = "parent.clockChanged")) 

Który będzie karmić wynik do klienta w kawałki. Obiekt Enumerator ma także funkcje wyliczające narzędzie użyteczności publicznej (jak w przypadku java.io.InputStream).

Nie jestem pewien, gdzie to się robi, ale założenie jest takie, że to porcjowane przetwarzanie nie wiąże wątków. Byłoby bardzo interesujące zobaczyć niektóre benchmarki, ponieważ na pewno jest narzut w implementacji iteracji, ponieważ dane do przetworzenia, a także obliczenia są zawijane w różne obiekty.

Dane pobierane z modułu wyliczającego są zawijane, dzięki czemu mogą wskazać, że jest więcej danych do przetworzenia lub dane dotarły do ​​końca (EOF). Przetwarzanie wyników iteracji jest również zawijane tak, że może wskazywać, czy wynik został obliczony na podstawie jakiegoś wejścia, czy też więcej danych wejściowych jest potrzebne do obliczenia wyniku. Polecam Johnowi De Goesowi "nescala presentation", który pokazuje ewolucję od złożenia do Iteratees. Edytowanie: Brendan McAdams ma ładne dni Scala 2012 presentation na Async i non-blocking - pod koniec prezentacji (~ 26min) dotyka on iteratees i jak to pomaga w przetwarzaniu stylu IO w stylu kursora bazy danych w stylu asynchronicznym.

Jedna reklamowana korzyść z Iteratees polega na tym, że komponują. Oto kilka sposobów, tworzą one:

• można nakarmić enumator andthen inny
• można mapa funkcją typu (T) => U nad wyliczający z T uzyskać wyliczający z U
• można przeplatać dwóch modułów wyliczających
• iteratee może zostawić pewne dane wejściowe do wykorzystania przez inne iteratee