Fixing Data Races in Event Bus #290

Manually merged
dan merged 1 commits from racefuzz into master 2019-11-12 20:58:48 +00:00
Owner
No description provided.
dan was assigned by sarah 2019-11-12 20:42:45 +00:00
Member
Drone Build Status: success https://build.openprivacy.ca/cwtch.im/cwtch/702
dan requested changes 2019-11-12 20:52:33 +00:00
@ -13,3 +19,4 @@
// the event.Manager.
type Queue interface {
Publish(event Event)
InChan() chan<- Event
Owner

Prolly should make InChan and OutChan private then (I think a few use cases will have to be moved to <- .Next() instead of <- .OutChan() (plugins maybe)

Prolly should make InChan and OutChan private then (I think a few use cases will have to be moved to <- .Next() instead of <- .OutChan() (plugins maybe)
@ -32,6 +39,12 @@ func NewSimpleQueue(buffer int) Queue {
return queue
}
func (sq *simpleQueue) Open() bool {
Owner

maybe name IsOpen()? this reads a bit as an action

maybe name IsOpen()? this reads a bit as an action
dan closed this pull request 2019-11-12 20:58:48 +00:00
dan closed this pull request 2019-11-12 20:58:48 +00:00
dan deleted branch racefuzz 2019-11-12 20:58:53 +00:00
Member
Drone Build Status: success https://build.openprivacy.ca/cwtch.im/cwtch/704
Sign in to join this conversation.
No description provided.