Commit 40bd589c authored by Jan Winkelmann's avatar Jan Winkelmann

gx publish 0.2.8

parent b3d19beb
0.2.7: QmPacwEp6wnpEEsLgEFuVCV2nPJwWPGWkAhvAYMAmUZokn 0.2.8: QmTd4zzRczqDrfGswY49biCg2kofMEJyGUBQjSShk89m4C
...@@ -96,13 +96,16 @@ func (re *responseEmitter) Emit(value interface{}) error { ...@@ -96,13 +96,16 @@ func (re *responseEmitter) Emit(value interface{}) error {
case cmdsutil.Error: case cmdsutil.Error:
re.w.Header().Set(StreamErrHeader, v.Error()) re.w.Header().Set(StreamErrHeader, v.Error())
case *cmdsutil.Error: case *cmdsutil.Error:
v.Error()
re.w.Header().Set(StreamErrHeader, v.Error()) re.w.Header().Set(StreamErrHeader, v.Error())
default: default:
err = re.enc.Encode(value) err = re.enc.Encode(value)
re.w.(http.Flusher).Flush() re.w.(http.Flusher).Flush()
} }
if err != nil {
log.Error(err)
}
return err return err
} }
...@@ -121,6 +124,7 @@ func (re *responseEmitter) Close() error { ...@@ -121,6 +124,7 @@ func (re *responseEmitter) Close() error {
func (re *responseEmitter) SetError(v interface{}, errType cmdsutil.ErrorType) { func (re *responseEmitter) SetError(v interface{}, errType cmdsutil.ErrorType) {
err := re.Emit(&cmdsutil.Error{Message: fmt.Sprint(v), Code: errType}) err := re.Emit(&cmdsutil.Error{Message: fmt.Sprint(v), Code: errType})
if err != nil { if err != nil {
log.Debug("http.SetError err=", err)
panic(err) panic(err)
} }
} }
......
...@@ -34,6 +34,6 @@ ...@@ -34,6 +34,6 @@
"language": "go", "language": "go",
"license": "MIT", "license": "MIT",
"name": "go-ipfs-cmds", "name": "go-ipfs-cmds",
"version": "0.2.7" "version": "0.2.8"
} }
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment