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

rsocket-rpc-net/RSocket.Rpc.Sample/Program.cs

Line 45 in 364913c

from value in Enumerable.Range(1, 3) select Value.ForString($"Test Channel Value {value}")

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