this repo has no description
readStream control messages to stderr
+5
-5
+5
-5
cmd/gosky/main.go
+5
-5
cmd/gosky/main.go
···
950
950
arg = fmt.Sprintf("%s?cursor=%s", arg, cctx.Args().Get(1))
951
951
}
952
952
953
-
fmt.Println("dialing: ", arg)
953
+
fmt.Fprintln(os.Stderr, "dialing: ", arg)
954
954
d := websocket.DefaultDialer
955
955
con, _, err := d.Dial(arg, http.Header{})
956
956
if err != nil {
···
960
960
jsonfmt := cctx.Bool("json")
961
961
unpack := cctx.Bool("unpack")
962
962
963
-
fmt.Println("Stream Started", time.Now().Format(time.RFC3339))
963
+
fmt.Fprintln(os.Stderr, "Stream Started", time.Now().Format(time.RFC3339))
964
964
defer func() {
965
-
fmt.Println("Stream Exited", time.Now().Format(time.RFC3339))
965
+
fmt.Fprintln(os.Stderr, "Stream Exited", time.Now().Format(time.RFC3339))
966
966
}()
967
967
968
968
go func() {
···
986
986
if unpack {
987
987
recs, err := unpackRecords(evt.Blocks, evt.Ops)
988
988
if err != nil {
989
-
fmt.Println("Failed to unpack records: ", err)
989
+
fmt.Fprintln(os.Stderr, "failed to unpack records: ", err)
990
990
}
991
991
out["records"] = recs
992
992
}
···
1006
1006
if unpack {
1007
1007
recs, err := unpackRecords(evt.Blocks, evt.Ops)
1008
1008
if err != nil {
1009
-
fmt.Println("failed to unpack records: ", err)
1009
+
fmt.Fprintln(os.Stderr, "failed to unpack records: ", err)
1010
1010
}
1011
1011
1012
1012
for _, rec := range recs {