How to unsubscribe from streaming topic

[terry-wilson]

I am trying to utilize the new pub/sub streaming capability and don't understand how to dynamically unsubscribe from a particular topic. In #1072, it states that "Daprd unsubscribes from the topic when the stream is closed" but I don't understand how the stream gets closed? I did take a look at the streaming pub/sub example but that doesn't seem to address unsubscribing either.

[artur-ciocanu]

@terry-wilson thanks you for raising this issue. We will take a look and let you know.

[terry-wilson]

@artur-ciocanu just wondering if there is any update on this ... given that you can dynamically subscribe to events, I would be very surprised if dynamically unsubscribing was somehow missed? I am hoping that I am just missing some basic understanding of how to do it.

[artur-ciocanu]

@terry-wilson as far as I understood based on the implementation once you subscribe you get a Subscription back. Once you are done with your processing you can call subscription.close() and this should close the GRPC stream and ubsubscribe from the previously subscribed topic.

The API is still a little bit in flux. We are trying to come up with something that is a little more Project Reactor friendly.