cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: BlockStream rpc: only cancel response context at the end

Browse Source
This commit is contained in:
Hector Sanjuan 2022-03-28 17:55:31 +02:00
parent 8908da32be
commit f07c1e6552
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
rpc_api.go
View File

@ -572,7 +572,7 @@ func (rpcapi *IPFSConnectorRPCAPI) SwarmPeers(ctx context.Context, in struct{},
// BlockStream runs IPFSConnector.BlockStream(). // BlockStream runs IPFSConnector.BlockStream().
func (rpcapi *IPFSConnectorRPCAPI) BlockStream(ctx context.Context, in <-chan api.NodeWithMeta, out chan<- struct{}) error { func (rpcapi *IPFSConnectorRPCAPI) BlockStream(ctx context.Context, in <-chan api.NodeWithMeta, out chan<- struct{}) error {
close(out) defer close(out) // very important to do at the end
return rpcapi.ipfs.BlockStream(ctx, in) return rpcapi.ipfs.BlockStream(ctx, in)
} }