Skip to content
Snippets Groups Projects
Commit dee47036 authored by Jono Wenger's avatar Jono Wenger
Browse files

Fix TestManager_ProcessMessageRetrieval_Quit again

parent d70b205b
No related branches found
No related tags found
1 merge request!23Release
...@@ -294,15 +294,17 @@ func TestManager_ProcessMessageRetrieval_Quit(t *testing.T) { ...@@ -294,15 +294,17 @@ func TestManager_ProcessMessageRetrieval_Quit(t *testing.T) {
messageBundleChan := make(chan message.Bundle) messageBundleChan := make(chan message.Bundle)
testManager.messageBundles = messageBundleChan testManager.messageBundles = messageBundleChan
// Initialize the message retrieval
go testManager.processMessageRetrieval(mockComms, stop)
// Close the process early, before any logic below can be completed // Close the process early, before any logic below can be completed
if err := stop.Close(); err != nil { if err := stop.Close(); err != nil {
t.Errorf("Failed to signal close to process: %+v", err) t.Errorf("Failed to signal close to process: %+v", err)
} }
time.Sleep(250 * time.Millisecond) if err := stoppable.WaitForStopped(stop, 300*time.Millisecond); err != nil {
t.Fatalf("Failed to stop stoppable: %+v", err)
// Initialize the message retrieval }
go testManager.processMessageRetrieval(mockComms, stop)
// Construct expected values for checking // Construct expected values for checking
expectedEphID := ephemeral.Id{1, 2, 3, 4, 5, 6, 7, 8} expectedEphID := ephemeral.Id{1, 2, 3, 4, 5, 6, 7, 8}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment