streams
Here are 927 public repositories matching this topic...
-
Updated
May 18, 2022 - JavaScript
Failures when Kafka Connectors has high number of tasks (limit on max bytes to buffer : 262144)
Describe the bug
Stack trace:
at org.springframework.web.reactive.function.client.WebClientResponseException.create(WebClientResponseException.java:229)
at org.springframework.web.reactive.function.client.DefaultClientResponse.lambda$createException$2(DefaultClientResponse.java:213)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:106)
at reactor.core.publisher.
-
Updated
May 23, 2022 - TypeScript
-
Updated
Mar 4, 2020 - JavaScript
-
Updated
Feb 11, 2022 - JavaScript
-
Updated
May 20, 2022 - Java
-
Updated
Feb 11, 2022 - Go
-
Updated
Apr 29, 2022 - TypeScript
Context
(Motivated by quarkusio/quarkus#21297)
The existing mutiny-kotlin module provides extensions methods for converting between Uni/Mutli and coroutines; however, it's missing a straightforward way to return a suspending function as a Uni.
[The example in the documentation](https://smallrye.io/smallry
-
Updated
May 16, 2022 - C#
-
Updated
May 19, 2020 - JavaScript
-
Updated
May 14, 2022 - Java
-
Updated
Sep 8, 2021 - JavaScript
-
Updated
Mar 24, 2022 - Python
-
Updated
Feb 16, 2021 - TypeScript
-
Updated
May 23, 2022 - TypeScript
-
Updated
May 4, 2022 - Scala
-
Updated
Dec 19, 2017 - Java
-
Updated
Feb 5, 2021 - Go
Improve this page
Add a description, image, and links to the streams topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the streams topic, visit your repo's landing page and select "manage topics."
allow to limit/annotate tests in a similar way we have for js, native, etc. when run using graalvm native-image