reactive-streams

Documentation Issue

The diagram legend at the top of the Flux/Mono javadoc page is awesome. However, the legend only mentions a very simple use case, and there are many other symbols used in the method diagrams that do not appear in the legend.

Improvement Suggestion

It would be super-awesome if the legend included all symbols used in the method diagrams.

For example:

Signal,

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

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.

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

Aug	SEP	Oct
	08
2019	2020	2021

reactive-streams

Here are 404 public repositories matching this topic...

ReactiveX / RxJava

reactor / reactor-core

Documentation Issue

Improvement Suggestion

uber / AutoDispose

ReactiveCocoa / ReactiveSwift

monix / monix

sksamuel / elastic4s

akka / alpakka-kafka

reactor / reactor-netty

aol / cyclops

akka / alpakka

outworkers / phantom

softwaremill / sttp

akarnokd / RxJavaInterop

hantsy / spring-reactive-sample

akarnokd / RxJavaExtensions

pgjdbc / r2dbc-postgresql

CombineCommunity / RxCombine

apple / servicetalk

scalecube / scalecube-services

jetlinks / jetlinks-community

CombineCommunity / CombineExt

shamansir / rpd

jetlinks / jetlinks

davidmoten / rxjava2-jdbc

r2dbc / r2dbc-client

hivemq / hivemq-mqtt-client

Problem or use case

Preferred solution or suggestions

akka / akka-grpc

mirromutth / r2dbc-mysql

reactor / reactive-streams-commons

raquo / Laminar

Improve this page

Add this topic to your repo