1 files changed, 0 insertions, 114 deletions
diff --git a/worker_test.go b/worker_test.go
index 43bb8b65..b8bd4c8b 100755
--- a/worker_test.go
+++ b/worker_test.go
@@ -64,117 +64,3 @@ func Test_OnStarted(t *testing.T) {
 
 	assert.Equal(t, "can't attach to running process", err.Error())
 }
-
-//func TestErrBuffer_Write_Len(t *testing.T) {
-//	buf := newErrBuffer(nil)
-//	defer func() {
-//		buf.Close()
-//	}()
-//
-//	_, err := buf.Write([]byte("hello"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//	assert.Equal(t, 5, buf.Len())
-//	assert.Equal(t, "hello", buf.String())
-//}
-//
-//func TestErrBuffer_Write_Event(t *testing.T) {
-//	buf := newErrBuffer(nil)
-//	defer func() {
-//		buf.Close()
-//	}()
-//
-//	wg := &sync.WaitGroup{}
-//	wg.Add(1)
-//	buf.logCallback = func(log []byte) {
-//		assert.Equal(t, []byte("hello\n"), log)
-//		wg.Done()
-//	}
-//	buf.enable = true
-//
-//	_, err := buf.Write([]byte("hello\n"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	wg.Wait()
-//
-//	// messages are read
-//	assert.Equal(t, 0, buf.Len())
-//}
-//
-//func TestErrBuffer_Write_Event_Separated(t *testing.T) {
-//	buf := newErrBuffer(nil)
-//	defer func() {
-//		buf.Close()
-//	}()
-//
-//	wg := &sync.WaitGroup{}
-//	wg.Add(1)
-//
-//	buf.logCallback = func(log []byte) {
-//		assert.Equal(t, []byte("hello\nending"), log)
-//		wg.Done()
-//	}
-//	buf.enable = true
-//
-//	_, err := buf.Write([]byte("hel"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	_, err = buf.Write([]byte("lo\n"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	_, err = buf.Write([]byte("ending"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	wg.Wait()
-//	assert.Equal(t, 0, buf.Len())
-//	assert.Equal(t, "", buf.String())
-//}
-//
-//func TestErrBuffer_Write_Event_Separated_NoListener(t *testing.T) {
-//	buf := newErrBuffer(nil)
-//	defer func() {
-//		buf.Close()
-//	}()
-//
-//	_, err := buf.Write([]byte("hel"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	_, err = buf.Write([]byte("lo\n"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	_, err = buf.Write([]byte("ending"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	assert.Equal(t, 12, buf.Len())
-//	assert.Equal(t, "hello\nending", buf.String())
-//}
-//
-//func TestErrBuffer_Write_Remaining(t *testing.T) {
-//	buf := newErrBuffer(nil)
-//	defer func() {
-//		buf.Close()
-//	}()
-//
-//	_, err := buf.Write([]byte("hel"))
-//	if err != nil {
-//		t.Errorf("fail to write: error %v", err)
-//	}
-//
-//	assert.Equal(t, 3, buf.Len())
-//	assert.Equal(t, "hel", buf.String())
-//}