These are chat archives for ReactiveX/RxJava

31st
Jan 2018
pbagchi
@pbagchi
Jan 31 2018 19:18

Hi, I am working on a project using Hystrix and gRPC. I have a HystrixObservableCommand class - MemberCommand and I am subscribing using Schedulers.io()

memberCommand.toObservable().subscribeOn(Schedulers.io());

In the construct method, I log the gRPC context but it returns null -

protected Observable<Greeter.GreeterReply> construct() {
 logger.info("0 -- In MemberCommand, traceId from gRPC context = {}", ContextKeys.TRACE_ID_CTX_KEY.get());

Any ideas, how I can propagate gRPC context through RxIoScheduler threads?

For the above I get,
0 -- In MemberCommand, traceId from gRPC context = null