Any way to use a grpc method as an RxJava observable?

[parrotcar00]

I have a simple use case of where I want to expose a RxJava observable through a stream method. I have code like:
`Observable myPojoSource = Observable.just(myPojo);

    myPojoSource.subscribe(myPojo -> {

        //Here I want to call my Grpc method
        myGrpcMethod(myPojoe, responseObserver); //How do I get hold of this responseObserver variable?

    });`

But how do I get hold of that responseObserver variable? Is there anyway to get it?

[parrotcar00]

To give some more context, I have a pojo on my Grpc server that gets updated in a hard to predict fashion. So it seemed like best to use RxJava to assign a subscriber call back method to work with this pojo.
Now I want to expose this pojo through a Grpc stream returning method but I'm confused how to call the grpc stream stub from the observer callback?

[jvmlet]

Please have a look at test in this commit