add example streamer

This commit is contained in:
2023-04-18 22:16:04 -07:00
parent 48f074cc9c
commit e2bb856589

View File

@@ -2,7 +2,6 @@ package main
import ( import (
"bufio" "bufio"
"bytes"
"context" "context"
"io" "io"
"log" "log"
@@ -24,18 +23,19 @@ func main() {
if err != nil { if err != nil {
panic(err) panic(err)
} }
buf := bytes.Buffer{} pipeReader, pipeWriter := io.Pipe()
w := bufio.NewWriter(&buf)
reader := bufio.NewReader(os.Stdin) reader := bufio.NewReader(os.Stdin)
text, _ := reader.ReadString('\n') text, _ := reader.ReadString('\n')
err = client.TTSWriter(ctx, w, text, ids[0], types.SynthesisOptions{Stability: 0.75, SimilarityBoost: 0.75}) go func() {
if err != nil { err = client.TTSStream(ctx, pipeWriter, text, ids[0], types.SynthesisOptions{Stability: 0.75, SimilarityBoost: 0.75})
panic(err) if err != nil {
} panic(err)
r := io.NopCloser(bytes.NewReader(buf.Bytes())) }
streamer, format, err := mp3.Decode(r) pipeWriter.Close()
}()
streamer, format, err := mp3.Decode(pipeReader)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }