event

type Emitter interface {
	Subscribable
	Publisher
	process.Process
}

type Publisher interface {
	Publish(ctx context.Context, message interface{}, tag query.Tagged) error
}

type PublisherFunc func(ctx context.Context, message interface{}, tags query.Tagged) error

type Subscribable interface {
	// Subscribe to all events matching query, which is a valid tmlibs Query. Blocking the out channel blocks the entire
	// pubsub.
	Subscribe(ctx context.Context, subscriber string, queryable query.Queryable, bufferSize int) (out <-chan interface{}, err error)
	// Unsubscribe subscriber from a specific query string. Note the subscribe channel must be drained.
	Unsubscribe(ctx context.Context, subscriber string, queryable query.Queryable) error
	UnsubscribeAll(ctx context.Context, subscriber string) error
}