Commit a67af7d9 authored by Jeromy's avatar Jeromy

remove unnecessary flush, and buffer output channel

parent ae929557
......@@ -91,7 +91,7 @@ remains to be implemented.
progress, _, _ := req.Option(progressOptionName).Bool()
wrap, _, _ := req.Option(wrapOptionName).Bool()
outChan := make(chan interface{})
outChan := make(chan interface{}, 8)
res.SetOutput((<-chan interface{})(outChan))
go func() {
......@@ -219,11 +219,6 @@ func add(n *core.IpfsNode, reader io.Reader) (*dag.Node, error) {
return nil, err
}
err = n.Pinning.Flush()
if err != nil {
return nil, err
}
return node, nil
}
......
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