Pytania oznaczone «stream»

162
Jak sklonować InputStream?

Mam InputStream, który przekazuję do metody, aby wykonać pewne przetwarzanie. Użyję tego samego InputStream w innej metodzie, ale po pierwszym przetworzeniu InputStream wydaje się być zamknięty wewnątrz metody. Jak mogę sklonować InputStream, aby wysłać go do metody, która go zamyka? Czy jest inne...

160
Czy można przesłać strumień w Javie 8?

Czy można przesyłać strumień w Javie 8? Powiedzmy, że mam listę obiektów, mogę zrobić coś takiego, aby odfiltrować wszystkie dodatkowe obiekty: Stream.of(objects).filter(c -> c instanceof Client) Po tym jednak, jeśli chcę coś zrobić z klientami, musiałbym obsadzić każdego z...

153
Odwrotna kolejność strumieni Java 8

Pytanie ogólne: Jaki jest właściwy sposób odwrócenia strumienia? Zakładając, że nie wiemy, z jakiego typu elementów składa się strumień, jaki jest ogólny sposób odwrócenia dowolnego strumienia? Konkretne pytanie: IntStreamzapewnia metodę zakresu do generowania liczb całkowitych w określonym...

147
Czy można czytać z InputStream z limitem czasu?

W szczególności problem polega na napisaniu takiej metody: int maybeRead(InputStream in, long timeout) gdzie wartość zwracana jest taka sama jak in.read (), jeśli dane są dostępne w milisekundach „timeout”, lub -2 w przeciwnym razie. Przed zwróceniem metody wszystkie utworzone wątki muszą zostać...

146
Czy możesz podzielić strumień na dwa strumienie?

Mam zestaw danych reprezentowany przez strumień Java 8: Stream<T> stream = ...; Widzę, jak to przefiltrować, aby uzyskać losowy podzbiór - na przykład Random r = new Random(); PrimitiveIterator.OfInt coin = r.ints(0, 2).iterator(); Stream<T> heads = stream.filter((x) ->...

143
Strumienie Java 8 - zbieraj a zmniejszaj

Kiedy użyjesz collect()vs reduce()? Czy ktoś ma dobre, konkretne przykłady, kiedy zdecydowanie lepiej jest iść w jedną lub drugą stronę? Javadoc wspomina, że ​​metoda collect () jest modyfikowalną redukcją . Biorąc pod uwagę, że jest to redukcja zmienna, zakładam, że wymaga synchronizacji...