Gabriel Volpe
Gabriel Volpe
@yisraelU sure, the more the merrier! You should have an invite now, thanks :)
@yisraelU unfortunately not. I think a good think would be to add MiMa support if that's something you'd be interested in contributing, as today we don't make any guarantees regarding...
> I was playing around with this. Somehow, setting the read to block = Some(1.millis) removes the flakiness (tested via 100+ runs). This doesn't make sense to me, since the...
> But the repeat does let us continue the read from the initial offset...? No, it would not, but there could be something wrong related to the `block` and `count`...
I don't think `repeat` is wrong, as we'd want a continuous stream of data from the XREAD source, but definitely some improvements could be made to the logic behind `block`...
Ah no problems, thanks for digging into it! I think what we can do immediately is to create a proper [withRedisStream](https://github.com/profunktor/redis4cats/blob/series/1.x/modules/tests/src/test/scala/dev/profunktor/redis4cats/Redis4CatsFunSuite.scala#L53) helper method for testing that returns two instances of...
Documentation for streams needs to be marked as experimental as well, and we could document that two streaming connections need to be created (one for read; one for write), similar...
I've tried this and it almost works. The remaining items after re-opening Telescope represent an incomplete list. For instance, if you initially have 5 items, and delete just one, then...
This works great: https://github.com/ThePrimeagen/harpoon/pull/512
This would be a great addition 👍🏽