project-reactor

0Hitze

1Antwort

Mit Haken und einen Aufzug schieben Context in Thread

ich mich gefragt, ob es ein Weg, um den reaktiven Kontext in eine Thread Variable zu drücken, bevor ein Teilnehmer das OnNext Signal empfangen. Beim Graben innerhalb des Reaktorkerns habe ich Hooks un

project-reactor 2017-11-26

---

0Hitze

1Antwort

Linke äußere Verbindung zwei sortierte dünne Sequenzen mit Projektreaktor

Gegeben sind zwei sortierte Ströme von Entitäten mit spärlichen IDs. Lassen Sie uns modellieren sie als: Flux<Long> stream1 = Flux.fromArray(new Long[] {1L, 3L, 4L, 5L, 6L}); Flux<Long> stream2 = Flu

java project-reactor reactive-streams 2017-11-27

---

0Hitze

1Antwort

Spring Web Reactive Framework-Multipart-Datei Ausgabe

Ich versuche Reactive Framework zu implementieren und Hochladen von Bildern mit Spring indem Sie versuchen, die folgenden: @RestController @RequestMapping("/images") public class ImageController {

spring spring-mvc reactive project-reactor 2017-12-07

---

1Hitze

1Antwort

Ich kann Benutzer nicht zu mongodb im Frühjahr speichern 5 WebFlux

Ich versuche, Benutzer zu Mongo-Datenbank im reaktiven Stil mit Spring WebFlux zu speichern, aber Daten werden nicht gespeichert, also habe ich Java 8, Spring 5 und mongodb. Das ist meine config: Mein

java mongodb project-reactor spring-webflux 2017-12-08

---

0Hitze

1Antwort

Spring Integration Rückstau Fehler beim Teilen großer Stream

Ziel ist es, eine große json.gz-Datei (4 GB komprimiert, etwa 12 GB unkomprimiert, 12 Millionen Zeilen) von einem Webserver direkt auf die Datenbank zu streamen, ohne lokal zu downloaden. Seit dem Frü

spring spring-integration reactive-programming project-reactor enterprise-integration 2017-12-09

---

0Hitze

1Antwort

Projekt-Reaktor: möglicherweise irreführende Dokumentation über die Fehlerbehandlung

Ich lese Reactor Referenzdokumentation über Fehlerbehandlung und etwas scheint falsch. Zum Beispiel in diesem Abschnitt über fallback method: Flux.just("key1", "key2") .flatMap(k -> callExternalS

spring project-reactor 2017-12-15

---

0Hitze

2Antwort

Reactor Scheduler laufen weiter, nachdem der Hauptthread erledigt wurde?

Ich habe eine Frage, wie die Scheduler-Worker-Threads, um aufzuräumen, während 3 unter Verwendung von Reactor Flux.range(1, 10000) .publishOn(Schedulers.newElastic("Y")) .doOnComplete(() -> { /

java project-reactor 2017-12-20

---

0Hitze

1Antwort

Warum Spring ReactiveMongoRepository hat keine Speichermethode für Mono?

Ich habe ein MovieRepository, das ReactiveMongoRepository erweitert. Ich möchte ein einzelnes POJO reaktiv speichern. Aber ReactiveMongoRepository bietet keine Speichermethode für Mono oder Publisher.

spring reactive-programming project-reactor 2017-12-21

---

1Hitze

1Antwort

Reaktor-Mapping Mono <Boolean> zu Mono <Void>

Ich habe Funktion, die Mono<Boolean> zurückgeben, und ich möchte es auf Mono<Void> zuordnen (da dies etwas ist, das ich in meiner Controller-Methode zurückgebe). Gibt es eine bessere Möglichkeit, Mono

spring project-reactor 2017-12-23

---

1Hitze

1Antwort

Reactive Stream auf finite Quelle bleibt offen für zukünftige Ereignisse

Ich verwende Spring Webflux, Spring Data und Project Reactor für nicht blockierende E/A (Spring Boot 2.0.0.M7). Mein Ziel ist es, eine Stock-Ticker-ähnliche API zu erstellen, die es einem Client erlau

spring-data reactive-programming project-reactor spring-webflux 2017-12-27

---