events

type Event interface {
	// MarshalToProtobuf maps events into API protobuf events.
	MarshalToProtobuf() *apigen.Event
}

type NewMessage struct {
	Message  entities.Message
	RoomName string
}

type PeerJoined struct {
	PeerID   peer.ID
	RoomName string
}

type PeerLeft struct {
	PeerID   peer.ID
	RoomName string
}

type Publisher interface {
	// Publish blocks until it is able to send the event through.
	Publish(Event) error

	// Closed checks whether the publisher is closed.
	Closed() bool
}

type Subscriber interface {
	// Next blocks until an event is received through the subscriber.
	Next() (Event, error)

	// Close closes the subscriber so it stops receiving new events.
	Close()
}