notifications

Documentation

Index

• type PubSub
  • func New() PubSub

Types

type PubSub

type PubSub interface {
	Publish(block auth.AuthBlock)
	Subscribe(ctx context.Context, keys ...cid.Cid) <-chan auth.AuthBlock
	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.