remote

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

type PubSub interface {
	Broadcast(topic string, msg proto.Message) error
	NewSubscriberProps(topic string) *actor.Props
	RegisterTopicValidator(topic string, validatorFunc PubSubValidator, opts ...pubsub.ValidatorOpt) error
	UnregisterTopicValidator(topic string)
	Subscribe(ctx spawner, topic string, subscribers ...*actor.PID) *actor.PID
}

type PubSubValidator func(context.Context, peer.ID, proto.Message) bool

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

type UnderlyingPubSub interface {
	Publish(topic string, data []byte) error
	RegisterTopicValidator(topic string, fn pubsub.Validator, opts ...pubsub.ValidatorOpt) error
	UnregisterTopicValidator(topic string) error
	Subscribe(topic string, opts ...pubsub.SubOpt) (UnderlyingSubscription, error)
}

type UnderlyingSubscription interface {
	Next(context.Context) (*pubsub.Message, error)
	Cancel()
}