-
Updated
Dec 5, 2020 - Java
reactive-streams
Here are 416 public repositories matching this topic...
-
Updated
Aug 28, 2020 - Java
-
Updated
Oct 27, 2020 - Swift
-
Updated
Dec 6, 2020 - Scala
-
Updated
Dec 6, 2020 - Scala
My following WebClient is working fine with internet connection but not through our proxy connection.
WebClient webClient = WebClient.builder()
.baseUrl("https://targetsite.com")
.build();
webClient.post()
.uri("/service/serviceName")
.body(BodyInserters.fromObject(reqData))
.retrieve()
.bodyToMono(WebServiceResponse.class)
Event though, the sam
-
Updated
Dec 6, 2020 - Scala
-
Updated
Sep 13, 2020 - Java
-
Updated
Dec 6, 2020 - Scala
-
Updated
Nov 9, 2020 - Scala
-
Updated
Dec 4, 2020 - Scala
-
Updated
Dec 3, 2020 - Java
-
Updated
Nov 13, 2020 - Java
-
Updated
Oct 14, 2020 - Swift
-
Updated
Dec 3, 2020 - Java
-
Updated
Dec 3, 2020 - Java
When a compressed payload is bigger than the acceptable limit the compression codec implementations throw an exception. Currently, this exception will be mapped to 500 on the server-side. Instead, we can catch that exception and respond with 413, according to the RFC: https://tools.ietf.org/html/rfc7231#section-6.5.11
-
Updated
Nov 23, 2020 - Swift
-
Updated
Nov 4, 2020 - Java
-
Updated
Dec 4, 2020 - Java
Problem or use case
The client is currently only logging errors and warnings. For debugging purposes and during application development, it would be very useful to also have logs detailing the message flow.
Preferred solution or suggestions
TRACE level logging for incoming and outgoing MQTT control packet types, e.g., PUBLISH, SUBSCRIBE, PUBACK, SUBACK.
-
Updated
Dec 6, 2020
-
Updated
May 19, 2020 - JavaScript
-
Updated
Oct 12, 2020 - Java
During akka-grpc-maven-plugin:0.6.0:generate, and likely other similar non akka-grpc tasks, if /tmp/ for this process is not accessible, or has the noexec mount option set:
Execution default of goal com.lightbend.akka.grpc:akka-grpc-maven-plugin:0.6.0:generate failed: protoc exit code 1: /tmp/protocbridge7686600923568091505: program not found or is not executable
Perhaps add a fal
-
Updated
Mar 21, 2019 - Java
-
Updated
Oct 17, 2020 - Scala
Improve this page
Add a description, image, and links to the reactive-streams topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the reactive-streams topic, visit your repo's landing page and select "manage topics."


Documentation Issue
from reading the documentation for Mono.thenReturn, I got the impression that if the previous Mono completed with an error, it would be discarded and the return value would be returned instead. After experimenting I learned this is not the case, and errors in the preceding pipe