reactive-streams

aside with FAIL_FAST.

More details here
violetagg/reactor-netty-workshop#2

Some instances of ExecutorExtension are declared as class static and marked as such with setClassLevel(true) which allows sharing of the executor instance between tests. More instances could possibly made class static which would reduce the overhead of creating executor instances for each test.

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.

Discussed in smallrye/smallrye-mutiny#742

^{Originally posted by michalszynkiewicz November 5, 2021}
For me, atLeast suggests that the value will be memoized/cached for the specified amount of time or longer (I'd guess might be stored in a weak reference after the period of time).

The discussion on a [Stor

We make sure in the CI configuration to build with jdk8, but it would be safer to specify this in the build (javacOptions/scalacOptions) explicitly.

reactive-streams

Here are 453 public repositories matching this topic...

ReactiveX / RxJava

hs-web / hsweb-framework

reactor / reactor-core

uber / AutoDispose

ReactiveCocoa / ReactiveSwift

jetlinks / jetlinks-community

monix / monix

reactor / reactor-netty

sksamuel / elastic4s

akka / alpakka-kafka

aol / cyclops

akka / alpakka

softwaremill / sttp

outworkers / phantom

hantsy / spring-reactive-sample

CombineCommunity / CombineExt

CombineCommunity / RxCombine

akarnokd / RxJavaInterop

pgjdbc / r2dbc-postgresql

apple / servicetalk

akarnokd / RxJavaExtensions

scalecube / scalecube-services

hivemq / hivemq-mqtt-client

Problem or use case

Preferred solution or suggestions

mirromutth / r2dbc-mysql

raquo / Laminar

jetlinks / jetlinks

smallrye / smallrye-mutiny

Discussed in smallrye/smallrye-mutiny#742

shamansir / rpd

akka / akka-grpc

tcldr / Entwine

Improve this page

Add this topic to your repo