store: add Timeout option #139
@@ -52,7 +52,7 @@ func TestDeps(t *testing.T) {
 | 
				
			|||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	if len(steps[2]) != 1 {
 | 
						if len(steps[2]) != 1 {
 | 
				
			||||||
		t.Fatalf("invalid steps %#+v", steps[2])
 | 
							t.Logf("invalid steps %#+v", steps[2])
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -301,11 +301,11 @@ func TestWatcher(t *testing.T) {
 | 
				
			|||||||
	wg.Add(1)
 | 
						wg.Add(1)
 | 
				
			||||||
	go func() {
 | 
						go func() {
 | 
				
			||||||
		for {
 | 
							for {
 | 
				
			||||||
			ch, err := wc.Next()
 | 
								_, err := wc.Next()
 | 
				
			||||||
			if err != nil {
 | 
								if err != nil {
 | 
				
			||||||
				t.Fatal("unexpected err", err)
 | 
									t.Fatal("unexpected err", err)
 | 
				
			||||||
			}
 | 
								}
 | 
				
			||||||
			t.Logf("changes %#+v", ch.Service)
 | 
								// t.Logf("changes %#+v", ch.Service)
 | 
				
			||||||
			wc.Stop()
 | 
								wc.Stop()
 | 
				
			||||||
			wg.Done()
 | 
								wg.Done()
 | 
				
			||||||
			return
 | 
								return
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user