Browse Source

fix startNotifyFlowHandler (issue #13)

pull/22/head
pwli 5 years ago
parent
commit
f838ee629d
1 changed files with 6 additions and 4 deletions
  1. +6
    -4
      publish.go

+ 6
- 4
publish.go View File

@ -218,15 +218,17 @@ func (publisher *Publisher) Publish(
}
func (publisher *Publisher) startNotifyFlowHandler() {
// Listeners for active=true flow control. When true is sent to a listener,
// publishing should pause until false is sent to listeners.
for ok := range publisher.notifyFlowChan {
publisher.disablePublishDueToFlowMux.Lock()
publisher.logger.Printf("pausing publishing due to flow request from server")
if ok {
publisher.disablePublishDueToFlow = false
} else {
publisher.logger.Printf("pausing publishing due to flow request from server")
publisher.disablePublishDueToFlow = true
} else {
publisher.disablePublishDueToFlow = false
publisher.logger.Printf("resuming publishing due to flow request from server")
}
publisher.disablePublishDueToFlowMux.Unlock()
publisher.logger.Printf("resuming publishing due to flow request from server")
}
}

Loading…
Cancel
Save