add test code for RedisSubscribeDrivenSource