mirror of
https://github.com/Luzifer/duplicity-backup.git
synced 2024-09-19 16:32:55 +00:00
33 lines
599 B
Go
33 lines
599 B
Go
package main
|
|
|
|
import "strings"
|
|
|
|
type messageChanWriter struct {
|
|
msgChan chan string
|
|
|
|
buffer []byte
|
|
}
|
|
|
|
func NewMessageChanWriter(outputChannel chan string) *messageChanWriter {
|
|
return &messageChanWriter{
|
|
msgChan: outputChannel,
|
|
buffer: []byte{},
|
|
}
|
|
}
|
|
|
|
func (m *messageChanWriter) Write(p []byte) (n int, err error) {
|
|
n = len(p)
|
|
err = nil
|
|
|
|
m.buffer = append(m.buffer, p...)
|
|
if strings.Contains(string(m.buffer), "\n") {
|
|
lines := strings.Split(string(m.buffer), "\n")
|
|
for _, l := range lines[:len(lines)-1] {
|
|
m.msgChan <- l
|
|
}
|
|
m.buffer = []byte(lines[len(lines)-1])
|
|
}
|
|
|
|
return
|
|
}
|