Merge pull request #43 from mumez/feature/stream-objects

Fixing flaky tests
mumez · Sep 16, 2024 · 2fadd95 · 2fadd95
2 parents 4b936dd + 7c6f1d7
commit 2fadd95
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...k-Stream-Objects-Tests.package/RsRedisStreamIteratorTest.class/instance/testSimplePoll.st b/...k-Stream-Objects-Tests.package/RsRedisStreamIteratorTest.class/instance/testSimplePoll.st
@@ -1,7 +1,7 @@
 tests
 testSimplePoll
 	| strm one two three four five ite1 entries1 ite2 entries2 |
-	strm := self newStreamNamed: 'testDoCollect'.
+	strm := self newStreamNamed: 'testSimplePoll'.
 	strm trimTo: 0.
 	self assert: strm length equals: 0.
 	one := 'one' -> '1'.

diff --git a/...jects-Tests.package/RsStreamConsumerGroupPollerTest.class/instance/testSimpleGroupPoll.st b/...jects-Tests.package/RsStreamConsumerGroupPollerTest.class/instance/testSimpleGroupPoll.st
@@ -20,8 +20,8 @@ testSimpleGroupPoll
 	1 to: 10 do: [ :idx |
 		strm nextPut: (('idx:', idx asString) -> idx).
 	].
+	(Delay forMilliseconds: 100) wait.
 	[consumerGroup summaryPendingList isEmpty] whileFalse: [ (Delay forMilliseconds: 100) wait].
-	(Delay forMilliseconds: 10) wait.
 
 	poller1 stop.
 	poller2 stop.