From 383e075a62ca4e4250c1d652913c4de375a03bc5 Mon Sep 17 00:00:00 2001
From: Luke Shumaker <lukeshu@beefcake.parabola.nu>
Date: Sat, 19 May 2018 02:20:59 -0400
Subject: async status line

---
 go/src/lib/statusline/async.go | 45 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 45 insertions(+)
 create mode 100644 go/src/lib/statusline/async.go

(limited to 'go/src/lib')

diff --git a/go/src/lib/statusline/async.go b/go/src/lib/statusline/async.go
new file mode 100644
index 0000000..32c9a2b
--- /dev/null
+++ b/go/src/lib/statusline/async.go
@@ -0,0 +1,45 @@
+package statusline
+
+import (
+	"io"
+	"time"
+)
+
+type AsyncStatusLine struct {
+	lines chan string
+	end   chan struct{}
+}
+
+func NewAsyncStatusLine(out io.Writer, d time.Duration) *AsyncStatusLine {
+	ret := &AsyncStatusLine{
+		lines: make(chan string),
+		end:   make(chan struct{}),
+	}
+	go func() {
+		sl := NewStatusLine(out)
+		ticker := time.NewTicker(d)
+		var line string
+		for {
+			select {
+			case <-ticker.C:
+				sl.Put(line)
+			case l := <-ret.lines:
+				line = l
+			case <-ret.end:
+				sl.End()
+				ticker.Stop()
+			}
+		}
+	}()
+	return ret
+}
+
+func (sl *AsyncStatusLine) Put(line string) {
+	sl.lines <- line
+}
+
+func (sl *AsyncStatusLine) End() {
+	sl.end <- struct{}{}
+	close(sl.lines)
+	close(sl.end)
+}
-- 
cgit v1.2.3-54-g00ecf