notifications

Documentation

Index

• type PubSub
  • func New() PubSub

Types

type PubSub

type PubSub interface {
	Publish(from peer.ID, blocks ...blocks.Block)
	Subscribe(ctx context.Context, keys ...cid.Cid) <-chan blocks.Block
	Shutdown()
}

PubSub is a simple interface for publishing blocks and being able to subscribe for cids. It's used internally by bitswap to decouple receiving blocks and actually providing them back to the GetBlocks caller.

func New

func New() PubSub

New generates a new PubSub interface.