Skip to content

Commit 4c0aca7

Browse files
authored
improve output of CLI mode for streaming APIs (#79)
1 parent e724d0f commit 4c0aca7

File tree

3 files changed

+3
-7
lines changed

3 files changed

+3
-7
lines changed

adapter/controller/cli.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package controller
22

33
import (
4-
"bytes"
54
"context"
65
"flag"
76
"fmt"
@@ -329,13 +328,10 @@ func (c *CLI) runAsCLI() int {
329328
return
330329
}
331330

332-
b := new(bytes.Buffer)
333-
if _, err := b.ReadFrom(res); err != nil {
331+
if _, err := io.Copy(c.ui.Writer(), res); err != nil {
334332
errCh <- err
335333
return
336334
}
337-
338-
c.ui.Println(b.String())
339335
}()
340336

341337
select {

meta/meta.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,5 +7,5 @@ import (
77
const AppName = "evans"
88

99
var (
10-
Version = semver.MustParse("0.5.0")
10+
Version = semver.MustParse("0.5.1")
1111
)

usecase/call.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ func (sw *bidiStreamSendWriter) sendRequest(ctx context.Context) {
265265
}
266266

267267
req, err := sw.inputter.Input(sw.rpc.RequestMessage())
268-
if err == io.EOF {
268+
if errors.Cause(err) == io.EOF {
269269
sw.s.Close()
270270
return
271271
}

0 commit comments

Comments
 (0)