tim2CF

Thanks @Gabriel439 ! A bit unrelated question.. is there any good way to handle nicely subscription misbehaviour in case handler receives unexpected values? Here is an example https://github.com/coingaming/lnd-client/blob/6760cbf23ad351b982fefad5585199eca818943b/src/LndClient/RPC.hs#L207-L212 There my...

Thanks! Any thoughts about proper termination of gRPC subscription *from inside of the handler*? From type signature I can't get any useful thoughts, because handler function returns `IO ()` value...

If I'm not calling recursively stream handler - subscription will just terminate? The bad thing about `IO ()` type is that there is no clear mechanism how to propagate the...

Thanks!

Hi again, @Gabriel439! Is it possible that gRPC subscription *client* is still non-cancellable from the *client* side with `cancel` function? I recently did some improvements on my library, trying to...

In my examples I'm using my own `spawnLink` and `withSpawnLink`, but they are just some generic wrappers around `async` + `link` and `withAsync` + `link` https://github.com/coingaming/lnd-client/blob/a1cae565f843e6ebbcd7734129463a72370bc81f/src/LndClient/Util.hs#L66-L81 I don't think this...

As additional info I can say that seems like process spawned like this is not cancellable. Can it be true? ```haskell -- spawning grpc subscription in new async thread pid...

I did compiled grpc-haskell with debug flag and found that subscription thread is hanging after log ``` [ThreadId 35]: runOps: allocated op contexts: [OpRecvMessageContext 0x000 07f9bc8000b70] [ThreadId 35]: runOps: tag:...

A took a look to gRPC-haskell source code a bit, and according my issue with **client** long subscription cancellation and logs produced in debug mode, it might be because of...

Cool, thanks Gabriel! Sorry for the spam. This library seems the only one complete gRPC library for Haskell and I had no idea how to fix the issue.