@@ -977,19 +977,16 @@ def test_seek(self):
977977
978978 # seek, and after reconnect, expected receive first message.
979979 consumer .seek (MessageId .earliest )
980- time .sleep (0.5 )
981980 msg = consumer .receive (TM )
982981 self .assertEqual (msg .data (), b"hello-0" )
983982
984983 # seek on messageId
985984 consumer .seek (ids [50 ])
986- time .sleep (0.5 )
987985 msg = consumer .receive (TM )
988986 self .assertEqual (msg .data (), b"hello-51" )
989987
990988 # ditto, but seek on timestamp
991989 consumer .seek (timestamps [42 ])
992- time .sleep (0.5 )
993990 msg = consumer .receive (TM )
994991 self .assertEqual (msg .data (), b"hello-42" )
995992
@@ -1000,23 +997,20 @@ def test_seek(self):
1000997
1001998 # earliest
1002999 reader .seek (MessageId .earliest )
1003- time .sleep (0.5 )
10041000 msg = reader .read_next (TM )
10051001 self .assertEqual (msg .data (), b"hello-0" )
10061002 msg = reader .read_next (TM )
10071003 self .assertEqual (msg .data (), b"hello-1" )
10081004
10091005 # seek on messageId
10101006 reader .seek (ids [33 ])
1011- time .sleep (0.5 )
10121007 msg = reader .read_next (TM )
10131008 self .assertEqual (msg .data (), b"hello-34" )
10141009 msg = reader .read_next (TM )
10151010 self .assertEqual (msg .data (), b"hello-35" )
10161011
10171012 # seek on timestamp
10181013 reader .seek (timestamps [79 ])
1019- time .sleep (0.5 )
10201014 msg = reader .read_next (TM )
10211015 self .assertEqual (msg .data (), b"hello-79" )
10221016 msg = reader .read_next (TM )
0 commit comments