reactive-streams

8Ciepło

1Odpowiedz

RxJava 2.0 - Jak przekonwertować obserwowalne do wydawcy

Jak przekonwertować obserwowalne do wydawcy w wersji RxJava 2? W pierwszej wersji mamy projekt https://github.com/ReactiveX/RxJavaReactiveStreams, który robi dokładnie to, czego potrzebuję. Ale jak mo

java reactive-programming reactivex reactive-streams rx-java2 2016-11-29

---

5Ciepło

2Odpowiedz

Java 9 Behavior of Flow SubmissionPublisher offer method

Grałem z operatorem Java Flow offer, ale po przeczytaniu dokumentacji i wykonaniu testu nie rozumiem. Oto moja próba @Test public void offer() throws InterruptedException { //Create Publisher fo

java java-9 reactive-streams java-flow 2017-09-30

---

14Ciepło

1Odpowiedz

Błąd w tworzeniu wykresu: wymaganie nie powiodło się: Wejścia [] i wyjścia [] muszą odpowiadać wlotom [w] i wylotom [out]

Używam strumieni akka graphDSL do utworzenia działającego wykresu. Nie ma błędów kompilacji podczas wlotu/wylotu komponentów strumienia. Środowisko wykonawcze zgłasza następujący błąd: Jakieś pomysły,

scala typesafe akka-stream reactive-streams 2016-02-17

---

7Ciepło

1Odpowiedz

Akka HTTP: Jak od niechcianej odpowiedzi formatu Json na obiekty domeny

Próbuję HTTP Akka, a ja stworzyłem usługę, która zwraca Json Array obiektów domeny w HttpResponse. W kliencie chcę przekonwertować go na źródło obiektów domeny, aby mógł zostać zużyty przez kolejne pr

json scala akka-stream akka-http reactive-streams 2015-10-01

---

6Ciepło

1Odpowiedz

Akka Strumienie podzielony przez strumień typu

mam następujący prosty przypadek hierarchię klasy: sealed trait Message case class Foo(bar: Int) extends Message case class Baz(qux: String) extends Message i mam Flow[Message, Message, NotUsed] (

scala akka akka-stream reactive-streams 2016-11-05

---

5Ciepło

1Odpowiedz

asynchroniczny, composable zwracana wartość dla danych wektorowych/potok w Javie 9

że mam API, które, na podstawie pewnych kryteriów zapytania, znajdzie lub budowę widżet: Widget getMatchingWidget(WidgetCriteria c) throws Throwable The (synchroniczne) wygląda kod klienta jak: try

java rx-java nonblocking java-9 reactive-streams 2017-10-19

---

8Ciepło

2Odpowiedz

Strumienie reaktywne - pakowanie z limitem czasu

Rozglądam się, aby wymienić bibliotekę przetwarzania logów, która wygląda okropnie blisko ReactiveStreams z io.projectreactor. Celem jest ograniczenie utrzymywanego przez nas kodu i korzystanie z nowy

rx-java reactive-programming project-reactor reactive-streams 2017-07-12

---

7Ciepło

2Odpowiedz

W pliku akka-stream, jak utworzyć nieuporządkowane źródło z kolekcji futures

Potrzebuję utworzyć akka.stream.scaladsl.Source[T, Unit] z kolekcji Future[T]. przykład zawierającą zbiór futures powracających całkowitymi, val f1: Future[Int] = ??? val f2: Future[Int] = ??? val f

scala future akka-stream reactive-streams 2015-09-06

---