-
Updated
Jan 19, 2021 - Java
reactive-streams
Here are 420 public repositories matching this topic...
-
Updated
Jan 14, 2021 - Java
-
Updated
Jan 15, 2021 - Java
-
Updated
Jan 12, 2021 - Swift
-
Updated
Jan 19, 2021 - Scala
-
Updated
Jan 24, 2021 - 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
Jan 11, 2021 - Scala
-
Updated
Dec 30, 2020 - Java
-
Updated
Jan 25, 2021 - Scala
-
Updated
Dec 27, 2020 - Scala
-
Updated
Jan 24, 2021 - Scala
-
Updated
Jan 22, 2021 - Java
-
Updated
Jan 18, 2021 - Java
-
Updated
Nov 13, 2020 - Java
-
Updated
Jan 1, 2021 - Swift
-
Updated
Jan 18, 2021 - Java
-
Updated
Jan 18, 2021 - 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
Jan 24, 2021 - Swift
-
Updated
Jan 12, 2021 - Java
-
Updated
Jan 22, 2021 - 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
Jan 19, 2021
-
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
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."


reactor.core.Scannable, method stepName
This code:
throws .StringIndexOutOfBoundsException for name:
ScopePassingSpanSubscriber{subscriber=reactor.core.publisher.MonoNext$NextSubscriber@1bf6ebc, parent=org.springframework.cloud.sleuth.api.noop.NoOpTraceContext@7110297e}I don't t