Commit b30eb0e7 authored by Brian Tiger Chow's avatar Brian Tiger Chow

feat(bitswap) broadcast block to routing, peers on receipt

parent ef92b55d
...@@ -118,6 +118,7 @@ func (bs *bitswap) ReceiveMessage( ...@@ -118,6 +118,7 @@ func (bs *bitswap) ReceiveMessage(
for _, block := range incoming.Blocks() { for _, block := range incoming.Blocks() {
go bs.blockstore.Put(block) // FIXME(brian): err ignored go bs.blockstore.Put(block) // FIXME(brian): err ignored
go bs.notifications.Publish(block) go bs.notifications.Publish(block)
go bs.HasBlock(ctx, block) // FIXME err ignored
} }
} }
......
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