subscribe never returns a result

[chrisjenx]

I can break the mock by using subscribe It looks like this should be implemented?

class JedisMockTest {

    private lateinit var redisServer: RedisServer
    private val jedis by lazy { Jedis(redisServer.host, redisServer.bindPort) }

    @Before
    fun setUp() {
        redisServer = RedisServer.newRedisServer()
        redisServer.start()
    }

    @After
    fun tearDown() {
        redisServer.stop()
    }

    @Test
    fun `test redis ping`() {
        val result = jedis.ping("Hello")
        assertEquals("Hello", result)
    }

    @Test
    fun `test pub sub`() {
        val countDownLatch = CountDownLatch(1)
        jedis.subscribe(object : JedisPubSub() {
            override fun onMessage(channel: String?, message: String?) {
                countDownLatch.countDown()
            }
        }, "channel")

//        jedis.publish("channel", "Message")

//        countDownLatch.await()
    }
}

The test will hang forever as it never gets a result from the subscribe call.

[chrisjenx]

Never mind closing, Jedis isn't clear, the sub needs to be inside it's own thread!

[chrisjenx]

This works incase anyone else gets stuck:

    @Test
    fun `test pub sub`() = runBlockingTest {
        val subscribed = CountDownLatch(1)
        val countDownLatch = CountDownLatch(1)
        val job = launch(Dispatchers.IO) {
            jedis.resource.use {
                it.subscribe(object : JedisPubSub() {
                    override fun onSubscribe(channel: String?, subscribedChannels: Int) {
                        println("Subscribed")
                        subscribed.countDown()
                    }

                    override fun onMessage(channel: String?, message: String?) {
                        println("onMessage: $message")
                        countDownLatch.countDown()
                    }
                }, "channel")
            }
        }

        launch(Dispatchers.IO) {
            subscribed.await(1000, TimeUnit.MILLISECONDS)
            jedis.resource.use { it.publish("channel", "Message") }
        }

        countDownLatch.await(1000, TimeUnit.MILLISECONDS)
        assertEquals(0, countDownLatch.count)
        job.cancel()
    }