forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-17 17:33:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/api: block api.Put with wait

Browse source
This commit is contained in:
Anton Evangelatov 2018-02-09 16:14:42 +01:00
parent 21771c11d1
commit 4a0bf28985
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
swarm/api/api_test.go
View file

@ -109,10 +109,11 @@ func TestApiPut(t *testing.T) {
content := "hello" content := "hello"
exp := expResponse(content, "text/plain", 0) exp := expResponse(content, "text/plain", 0)
// exp := expResponse([]byte(content), "text/plain", 0) // exp := expResponse([]byte(content), "text/plain", 0)
key, _, err := api.Put(content, exp.MimeType) key, wait, err := api.Put(content, exp.MimeType)
if err != nil { if err != nil {
t.Fatalf("unexpected error: %v", err) t.Fatalf("unexpected error: %v", err)
} }
wait()
resp := testGet(t, api, key.Hex(), "") resp := testGet(t, api, key.Hex(), "")
checkResponse(t, resp, exp) checkResponse(t, resp, exp)
}) })

3
swarm/api/storage.go
View file

@ -42,10 +42,11 @@ func NewStorage(api *Api) *Storage {
// //
// DEPRECATED: Use the HTTP API instead // DEPRECATED: Use the HTTP API instead
func (self *Storage) Put(content, contentType string) (string, error) { func (self *Storage) Put(content, contentType string) (string, error) {
key, _, err := self.api.Put(content, contentType) key, wait, err := self.api.Put(content, contentType)
if err != nil { if err != nil {
return "", err return "", err
} }
wait()
return key.Hex(), err return key.Hex(), err
} }