issues Search Results · repo:grafov/bcast language:Go
Filter by
10 results
(88 ms)10 results
ingrafov/bcast (press backspace or delete to remove)So i have a piece of code:
for {
msg := v.Recv()
c.Send(msg.(string))
}
What ...
ghost
- 4
- Opened on Nov 11, 2018
- #18
I use your awesome library for years, but when switching to go1.9 dep seems to favour a released version instead of the
master branch - somehow makes sense. :)
Can you release a new version, so that it ...
enhancement
ChristianKniep
- 1
- Opened on Aug 28, 2017
- #17
// Leave removes the provided member from the group
func (g *Group) Leave(leaving *Member) error {
g.memberLock.Lock()
memberIndex := -1
for index, member := range g.members {
if member == leaving ...
bug
wuxc
- 1
- Opened on Jul 5, 2017
- #16
Can be useful if sender could wait until all members has received the broadcast message .
Thank you very much
toni-moreno
- 1
- Opened on May 11, 2017
- #14
The README.md is no longer reflective of changes that seem to have been made in the past few days. I can see the pull
request that was merged suggests a massive refactor ... it would be quite useful to ...
sb10
- 1
- Opened on Mar 7, 2017
- #13
https://github.com/grafov/bcast/blob/master/bcast.go#L114
go func(out chan interface{}, received *Message) { // non blocking
out - received.payload
}(member, received)
This code can block, and ...
bug
dpc
- 3
- Opened on Oct 18, 2016
- #12
I believe that this is because there is a race condition at
https://github.com/grafov/bcast/blob/79e4f3588b37ee0e71715d65fb537a2c49383688/bcast.go#L112 and
https://github.com/grafov/bcast/blob/79e4f3588b37ee0e71715d65fb537a2c49383688/bcast.go#L150 ...
colonelpanic8
- 2
- Opened on Sep 22, 2015
- #9
Hey there, I was looking into your bcast library and noticed some tests fail on my machine with Go 1.5.1:
dq@empit:bcast$ go test -v
=== RUN TestNewGroupAndJoin
--- PASS: TestNewGroupAndJoin (0.00s) ...
bug
ghost
- 3
- Opened on Sep 19, 2015
- #8
When invoking the Broadcasting method on a created Group with duration zero, the for loop in the function enters a tight
loop. I believe this is because the test of
case -time.After(timeout):
is always ...
enhancement
matthewmcneely
- 1
- Opened on Feb 26, 2015
- #4
Hi,
can you select between buffered and unbuffered broadcasting channel?
I would like to send a broadcast message to routine1 and routine2 using a broadcast channel...
go receiveData() { broadcast - ...
question
geraldstanje
- Opened on Nov 26, 2014
- #1

Learn how you can use GitHub Issues to plan and track your work.
Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub IssuesProTip!
Press the /
key to activate the search input again and adjust your query.
Learn how you can use GitHub Issues to plan and track your work.
Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub IssuesProTip!
Press the /
key to activate the search input again and adjust your query.