Function TestLoggerLogsAllDurableUpdates

tasklog/log_test.go:174–196

(t *testing.T)

}

func TestLoggerLogsAllDurableUpdates(t *testing.T) {
	var buf bytes.Buffer

	l := NewLogger(&buf, ForceProgress(true))
	l.widthFn = func() int { return 0 }
	l.throttle = 15 * time.Minute

	t1 := make(chan *Update)
	go func() {
		t1 <- &Update{"first", time.Now(), false}  // t = 0+ε  ms, throttle is open
		t1 <- &Update{"second", time.Now(), false} // t = 0+2ε ms, throttle is closed
		close(t1)                                  // t = 0+3ε ms, throttle is closed
	}()

	l.Enqueue(UnthrottledChanTask(t1))
	l.Close()

	assert.Equal(t, strings.Join([]string{
		"first\r",
		"second\r",
		"second, done.\n",
	}, ""), buf.String())
}

func TestLoggerHandlesSilentTasks(t *testing.T) {
	var buf bytes.Buffer