mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-16 18:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Update pinecone demos to use for range over incoming events

Browse source
This commit is contained in:
Devon Hudson 2022-11-17 15:39:10 -07:00
parent 7b34b10aae
commit eb00c632cf
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
2 changed files with 38 additions and 44 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
build/gobind-pinecone/monolith.go
View file

@ -434,9 +434,7 @@ func (m *DendriteMonolith) Start() {
go func(ch <-chan pineconeEvents.Event) { go func(ch <-chan pineconeEvents.Event) {
eLog := logrus.WithField("pinecone", "events") eLog := logrus.WithField("pinecone", "events")
for { for event := range ch {
select {
case event := <-ch:
switch e := event.(type) { switch e := event.(type) {
case pineconeEvents.PeerAdded: case pineconeEvents.PeerAdded:
case pineconeEvents.PeerRemoved: case pineconeEvents.PeerRemoved:
@ -459,7 +457,6 @@ func (m *DendriteMonolith) Start() {
default: default:
} }
} }
}
}(pineconeEventChannel) }(pineconeEventChannel)
} }

5
cmd/dendrite-demo-pinecone/main.go
View file

@ -303,9 +303,7 @@ func main() {
go func(ch <-chan pineconeEvents.Event) { go func(ch <-chan pineconeEvents.Event) {
eLog := logrus.WithField("pinecone", "events") eLog := logrus.WithField("pinecone", "events")
for { for event := range ch {
select {
case event := <-ch:
switch e := event.(type) { switch e := event.(type) {
case pineconeEvents.PeerAdded: case pineconeEvents.PeerAdded:
case pineconeEvents.PeerRemoved: case pineconeEvents.PeerRemoved:
@ -328,7 +326,6 @@ func main() {
default: default:
} }
} }
}
}(pineconeEventChannel) }(pineconeEventChannel)
base.WaitForShutdown() base.WaitForShutdown()