File tree 1 file changed +5
-1
lines changed
1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -90,6 +90,10 @@ public async Task All_messages_should_be_processed_even_with_multiple_buses_in_a
90
90
await buses [ rnd . Next ( ) % buses . Length ] . PublishAsync ( messages , cancellationToken ) ;
91
91
}
92
92
93
+ // Force a read of all messages to work around timing issues
94
+ await messagebus1 . ReadAsync ( ) ;
95
+ await messagebus2 . ReadAsync ( ) ;
96
+
93
97
// Add a new bus to the mix
94
98
using var messagebus3 = new TinyMessageBus ( name ) ;
95
99
@@ -101,7 +105,7 @@ public async Task All_messages_should_be_processed_even_with_multiple_buses_in_a
101
105
await buses [ rnd . Next ( ) % buses . Length ] . PublishAsync ( messages , cancellationToken ) ;
102
106
}
103
107
104
- // Force a final read of all messages to work around timing issuees
108
+ // Force a final read of all messages to work around timing issues
105
109
await messagebus1 . ReadAsync ( ) ;
106
110
await messagebus2 . ReadAsync ( ) ;
107
111
await messagebus3 . ReadAsync ( ) ;
You can’t perform that action at this time.
0 commit comments