Increasing unit test timeout for waitOnStreamCurrent from 10 to 30 sec

Signed-off-by: Matthias Hanel <mh@synadia.com>
This commit is contained in:
Matthias Hanel
2021-03-08 18:51:29 -05:00
parent 4d1fc3a449
commit fdcebf5c3a

View File

@@ -5048,7 +5048,7 @@ func (c *cluster) streamLeader(account, stream string) *Server {
func (c *cluster) waitOnStreamCurrent(s *Server, account, stream string) {
c.t.Helper()
expires := time.Now().Add(10 * time.Second)
expires := time.Now().Add(30 * time.Second)
for time.Now().Before(expires) {
if s.JetStreamIsStreamCurrent(account, stream) {
time.Sleep(100 * time.Millisecond)