pubsub

type Message interface {
	GetSource() peer.ID
	GetSender() peer.ID
	GetData() []byte
}

type Subscription interface {
	// Topic returns this subscription's topic name
	Topic() string
	// Next returns the next message from this subscription
	Next(ctx context.Context) (Message, error)
	// Cancel cancels this subscription
	Cancel()
}

type Topic struct {
	// contains filtered or unexported fields
}