remove unused input param
This commit is contained in:
@@ -46,7 +46,7 @@ import (
|
||||
|
||||
func TestExtractFromNonExistentFile(t *testing.T) {
|
||||
ch := make(chan interface{}, 1)
|
||||
c := newSourceFile("/some/fake/file", "localhost", time.Millisecond, ch)
|
||||
c := newSourceFile("/some/fake/file", "localhost", ch)
|
||||
err := c.watch()
|
||||
if err == nil {
|
||||
t.Errorf("Expected error")
|
||||
@@ -137,7 +137,7 @@ func TestExtractFromBadDataFile(t *testing.T) {
|
||||
}
|
||||
|
||||
ch := make(chan interface{}, 1)
|
||||
c := newSourceFile(fileName, "localhost", time.Millisecond, ch)
|
||||
c := newSourceFile(fileName, "localhost", ch)
|
||||
err = c.resetStoreFromPath()
|
||||
if err == nil {
|
||||
t.Fatalf("expected error, got nil")
|
||||
@@ -153,7 +153,7 @@ func TestExtractFromEmptyDir(t *testing.T) {
|
||||
defer os.RemoveAll(dirName)
|
||||
|
||||
ch := make(chan interface{}, 1)
|
||||
c := newSourceFile(dirName, "localhost", time.Millisecond, ch)
|
||||
c := newSourceFile(dirName, "localhost", ch)
|
||||
err = c.resetStoreFromPath()
|
||||
if err != nil {
|
||||
t.Fatalf("unexpected error: %v", err)
|
||||
|
Reference in New Issue
Block a user