Sample Channel functionality not working

[stevehayles]

I have been struggling with plugging the library into a third party Actor system and adding a TCP client / server implementation. I am trying to replace the existing gRPC based version built into that library.

I have it working apart from when it comes to using bi-directional channels. To simplify the issue I wanted to check against a working implementation but this sample has the same behaviour. Running the sample 'as is' will effectively wait indefinitely at https://github.com/rsocket/rsocket-rpc-net/blob/364913ce745d044d9e3ba815a0a88c73fd7f1eec/RSocket.Rpc.Sample/Program.cs#L45

Observable async code like this becomes very hard to debug and track down issues! Any thoughts or help very gratefully received