@@ -977,19 +977,16 @@ def test_seek(self):
977
977
978
978
# seek, and after reconnect, expected receive first message.
979
979
consumer .seek (MessageId .earliest )
980
- time .sleep (0.5 )
981
980
msg = consumer .receive (TM )
982
981
self .assertEqual (msg .data (), b"hello-0" )
983
982
984
983
# seek on messageId
985
984
consumer .seek (ids [50 ])
986
- time .sleep (0.5 )
987
985
msg = consumer .receive (TM )
988
986
self .assertEqual (msg .data (), b"hello-51" )
989
987
990
988
# ditto, but seek on timestamp
991
989
consumer .seek (timestamps [42 ])
992
- time .sleep (0.5 )
993
990
msg = consumer .receive (TM )
994
991
self .assertEqual (msg .data (), b"hello-42" )
995
992
@@ -1000,23 +997,20 @@ def test_seek(self):
1000
997
1001
998
# earliest
1002
999
reader .seek (MessageId .earliest )
1003
- time .sleep (0.5 )
1004
1000
msg = reader .read_next (TM )
1005
1001
self .assertEqual (msg .data (), b"hello-0" )
1006
1002
msg = reader .read_next (TM )
1007
1003
self .assertEqual (msg .data (), b"hello-1" )
1008
1004
1009
1005
# seek on messageId
1010
1006
reader .seek (ids [33 ])
1011
- time .sleep (0.5 )
1012
1007
msg = reader .read_next (TM )
1013
1008
self .assertEqual (msg .data (), b"hello-34" )
1014
1009
msg = reader .read_next (TM )
1015
1010
self .assertEqual (msg .data (), b"hello-35" )
1016
1011
1017
1012
# seek on timestamp
1018
1013
reader .seek (timestamps [79 ])
1019
- time .sleep (0.5 )
1020
1014
msg = reader .read_next (TM )
1021
1015
self .assertEqual (msg .data (), b"hello-79" )
1022
1016
msg = reader .read_next (TM )
0 commit comments