summaryrefslogtreecommitdiff
path: root/go/src/lib
diff options
context:
space:
mode:
Diffstat (limited to 'go/src/lib')
-rw-r--r--go/src/lib/statusline/async.go45
1 files changed, 45 insertions, 0 deletions
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)
+}