Using embedded subscribe and external client leads to io timeout

[Olex1313]

Hello, I've been using miniredis in my unit-tests and found unexpected behaviour when trying to subscribe with miniredis client and publish with https://github.com/redis/go-redis, which led to io timeout on publisher. Then I've switched to go-redis on both sides which worked fine. Am I doing something wrong or is it a bug?

I've attach a minimal reproducing example later

[alicebob]

Hello, I've been using miniredis in my unit-tests and found unexpected behaviour when trying to subscribe with miniredis client and publish with https://github.com/redis/go-redis, which led to io timeout on publisher. Then I've switched to go-redis on both sides which worked fine. Am I doing something wrong or is it a bug?

Sounds like a bug :)

I've attach a minimal reproducing example later

That would be great, thanks!

[alicebob]

Also, make sure you use the /v2 version of miniredis.

[Olex1313]

I've tried something like this:

func main() {
	mRedis, _ := miniredis.Run()
	mRedis.RequireUserAuth("hello", "world")
	redisUrl, _ := redis.ParseURL(fmt.Sprintf("redis://hello:world@%s", mRedis.Addr()))
	redisClient := redis.NewClient(redisUrl)

	miniSub := mRedis.NewSubscriber()
	miniSub.Subscribe("channel")

	curTime := time.Now()
	redisClient.Publish(context.Background(), "channel", "msg")
	println(time.Since(curTime) / 1000000000)

	curTime = time.Now()
	msgChan := miniSub.Messages()
	println(time.Since(curTime))

	select {
	case msg := <-msgChan:
		println(msg.Message)
	case <-time.After(time.Millisecond * 200):
		println("Too long")
	}
}

Apparently the problem is not exactly with publish, but somehow redis-go publishes a message approx 12 seconds :)

Miniredis version: github.com/alicebob/miniredis/v2 v2.30.5 redis-go version: github.com/redis/go-redis/v9 v9.1.0

[Olex1313]

I'll try to benchmark with native-redis, dockerized-redis and miniredis today, when I have more free time, but it looks strange, maybe it is even redis client issue

[alicebob]

The problem is that "Publish" writes to a channel where nothing is reading on. If you change that to work in a Go routine it works for me:

    ...
    curTime := time.Now()
    go func() {
        redisClient.Publish(context.Background(), "channel", "msg")
        println(time.Since(curTime) / 1000000000)
    }()
    ...