parent
e290130386
commit
78ffa91c4a
1 changed files with 3 additions and 1 deletions
|
|
@ -419,7 +419,9 @@ class StreamRefsSpec extends AkkaSpec(StreamRefsSpec.config()) {
|
|||
|
||||
// "concurrently"
|
||||
ks.shutdown()
|
||||
remoteControl.success(None)
|
||||
// note that while unlikely the killswitch shutdown can already have reached the source.maybe and in that case the
|
||||
// remoteControl is already completed here
|
||||
remoteControl.trySuccess(None)
|
||||
|
||||
// since it is a race we can only confirm that it either completes or fails both sides
|
||||
// if it didn't work
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue