feat(backend/ender): comsuming
This commit is contained in:
parent
f4883f481c
commit
9892e63a51
1 changed files with 1 additions and 2 deletions
|
|
@ -205,8 +205,7 @@ func main() {
|
|||
sessionEndGenerator.Enable()
|
||||
}
|
||||
default:
|
||||
// TODO: will trigger on every tick
|
||||
if memoryManager.HasFreeMemory() {
|
||||
if !memoryManager.HasFreeMemory() {
|
||||
continue
|
||||
}
|
||||
if err := consumer.ConsumeNext(); err != nil {
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue