Skip to content

Commit

Permalink
updates after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
shannonwells committed Jan 8, 2020
1 parent 575a01b commit 7c26e57
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 5 deletions.
4 changes: 2 additions & 2 deletions retrievalmarket/network/deal_stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,6 @@ func (d *DealStream) WriteDealPayment(dpy retrievalmarket.DealPayment) error {
return cborutil.WriteCborRPC(d.rw, &dpy)
}

func (d *DealStream) Close() {
d.rw.Close()
func (d *DealStream) Close() error {
return d.rw.Close()
}
1 change: 0 additions & 1 deletion retrievalmarket/network/network.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package network
import (
"github.com/filecoin-project/go-fil-components/retrievalmarket"
"github.com/libp2p/go-libp2p-core/peer"
peer "github.com/libp2p/go-libp2p-peer"
)

type RetrievalQueryStream interface {
Expand Down
4 changes: 2 additions & 2 deletions retrievalmarket/network/query_stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,6 @@ func (qs *QueryStream) WriteQueryResponse(qr retrievalmarket.QueryResponse) erro
return cborutil.WriteCborRPC(qs.rw, &qr)
}

func (qs *QueryStream) Close() {
qs.rw.Close()
func (qs *QueryStream) Close() error {
return qs.rw.Close()
}

0 comments on commit 7c26e57

Please sign in to comment.