Skip to content

Commit 788e2ee

Browse files
committed
refactor(sync-server): change channel to non-buffered
1 parent 2cd5bab commit 788e2ee

File tree

2 files changed

+3
-10
lines changed

2 files changed

+3
-10
lines changed

internal/tui/speaker_notes.go

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ func NewSpeakerNotes(rootSlide *Slide) SpeakerNotesModel {
7878
}
7979

8080
// Create buffered channel for slide changes
81-
slideChangeChan := make(chan int, 10)
81+
slideChangeChan := make(chan int)
8282

8383
return SpeakerNotesModel{
8484
currentSlide: 0,
@@ -123,10 +123,7 @@ func (m SpeakerNotesModel) listenForSlideChangesWithReconnect() {
123123
m.syncClient.ListenForSlideChanges(m.slideChangeChan)
124124

125125
// If we reach here, the connection was lost
126-
select {
127-
case m.slideChangeChan <- -1:
128-
default:
129-
}
126+
m.slideChangeChan <- -1
130127
}
131128

132129
func (m SpeakerNotesModel) attemptReconnect() tea.Cmd {

internal/tui/sync_server.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -137,11 +137,7 @@ func (c *SyncClient) ListenForSlideChanges(slideChangeChan chan<- int) {
137137
if strings.HasPrefix(line, "SLIDE:") {
138138
slideNumStr := strings.TrimPrefix(line, "SLIDE:")
139139
if slideNum, err := strconv.Atoi(slideNumStr); err == nil {
140-
select {
141-
case slideChangeChan <- slideNum:
142-
default:
143-
// Channel is full, skip this update
144-
}
140+
slideChangeChan <- slideNum
145141
}
146142
}
147143
}

0 commit comments

Comments
 (0)