WIP: not closing channels quite yet
This commit is contained in:
@ -43,6 +43,8 @@ func ListenNewImageEvents(db *sql.DB, eventManager *EventManager) {
|
|||||||
|
|
||||||
databaseEventLog.Debug("Starting processing image", "ImageID", imageId)
|
databaseEventLog.Debug("Starting processing image", "ImageID", imageId)
|
||||||
|
|
||||||
|
time.Sleep(10 * time.Second)
|
||||||
|
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
@ -119,8 +121,8 @@ func ListenProcessingImageStatus(db *sql.DB, eventManager *EventManager) {
|
|||||||
logger.Info("Sending...")
|
logger.Info("Sending...")
|
||||||
imageListener <- status
|
imageListener <- status
|
||||||
|
|
||||||
close(imageListener)
|
// close(imageListener)
|
||||||
delete(eventManager.listeners, stringUuid)
|
// delete(eventManager.listeners, stringUuid)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user