ravadre / rxredis Goto Github PK

I have executed this test:

1. Modified the test app Program.cs

            sbj.OnNext(5);
            sbj.OnNext(6);
            Console.ReadKey();
            sbj.OnNext(7);

            sbj.OnNext(8);
            Console.ReadKey();
            sbj.OnNext(9);
            Console.ReadKey();
            sbj.OnCompleted();

            Console.ReadLine();

1. Run external Redis client and subscribed to channel s1
2. Run the test app
3. The external client receives messages, ok.
4. In the external Redis client I published to channel s1 message: 1
5. There is exception:

private void OnMessage(RedisChannel redisChannel, RedisValue redisValue)
        {
            var msg = JSON.Deserialize<Message<T>>(redisValue);

An exception of type 'Jil.DeserializationException' occurred in Jil.dll but was not handled in user code
Additional information: Expected: {, null

Note. When I run 2 test app (modified as I wrote above) they work fine.

Great work @Ravadre !

RxRedis will be shared in our next RedisWeekly today!

Wow, this is an incredibly good idea. I am going to use this on my gaming servers, hope you work out the network error handling soon.