reactive-grpc

reactive-grpc copied to clipboard

issue #292 - discard support

7

please review, @rmichela

bruto1

Hi folks, I found a problem when I use it like below. ```java stub = xxx.newReactorStub(channel); stub.manyToMany(Flux.range(1, 10).map(i -> Message.newBuilder().setNumber(i).build()) .doOnNext(System.out::println)); ``` When I did not subscribe, the client terminal...

JooKS-me

Using the example in the README, can we have this method signature ``` ReactorGreeterGrpc.GreeterImplBase svc = new ReactorGreeterGrpc.GreeterImplBase() { @Override public Mono sayHello(HelloRequest request) { return greet("Hello", request); } };...

deepak-auto

Async resource cleanup failed after onComplete / call already closed

2

Hello, I ran into an issue using "spring-boot-starter-data-mongodb-reactive". When calling this server method, see two errors ("Async resource cleanup failed after onComplete", "call already closed") on the server (see attached...

owetterau

host_javabase is deprecated

1

Since bazel 5.0 the parameter used here is deprecated: https://github.com/salesforce/reactive-grpc/blob/071f153e61c2f8dcd1df287b51dd71cd34a39fd3/bazel/java_reactive_grpc_library.bzl#L74 Generating the following error: ``` Traceback (most recent call last): File "/home/juan/.cache/bazel/_bazel_juan/7e6e30ecb52b472e0900bbc0b820a797/external/com_salesforce_servicelibs_reactive_grpc/bazel/java_reactive_grpc_library.bzl", line 71, column 36, in _reactive_grpc_library_impl java_info =...

juanpmarin

Provide a way to override "prepareError()" to prepare meaningful errors in one place and handle 'jvm fatal' exceptions

1

Default static implementation of "prepareErrors" in * com.salesforce.reactorgrpc.stub.ServerCalls * com.salesforce.rx3grpc.stub.ServerCalls * com.salesforce.rxgrpc.stub.ServerCalls can't be customized. But sometimes it is very helpful: 1. You can define generic exception mapping on a...

lobanovdmitry

[reactor-grpc] Reactor context does not propagate if stub is used

18

Description -- Whenever a stub is used in a chain together with Reactor's [Context API](https://projectreactor.io/docs/core/release/reference/#_the_context_api) the provided context does not propagate correctly. My guess is, that using `subscribe()` within [ClientCalls](https://github.com/salesforce/reactive-grpc/blob/2b571218655674450ddd0b45af38b5bb0afd0915/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ClientCalls.java)...

krakowski

Currently, upon cancellation it just clears the queue, but its elements, for example, can be backed by reference counted objects which need to be released before being garbage collected (it's...

bruto1

Bumps [Google.Protobuf](https://github.com/protocolbuffers/protobuf) from 3.6.1 to 3.15.0. Release notes Sourced from Google.Protobuf's releases. Protocol Buffers v3.15.0 Protocol Compiler Optional fields for proto3 are enabled by default, and no longer require the...

dependabot[bot]

Set error code and error message?

7

Hi, How can I set error codes and error messages when using reactive-grpc with Reactor? Currently, my grpc server only sends errors with Code: Unknown and empty messages. Thank you.

ghost