mirror of
https://github.com/bitcoin-s/bitcoin-s.git
synced 2025-03-26 21:42:48 +01:00
Fix race condition in websocket tests for dlc node updates (#4866)
* Fix race condition in websocket tests for dlc node updates * Empty commit to run CI
This commit is contained in:
parent
f8ccead8b4
commit
24e7bcfd97
1 changed files with 9 additions and 6 deletions
|
@ -460,6 +460,7 @@ class WebsocketTests extends BitcoinSServerMainBitcoindFixture {
|
|||
.singleWebSocketRequest(req, websocketFlow)
|
||||
}
|
||||
|
||||
val setupF = notificationsF._1
|
||||
val walletNotificationsF: Future[Seq[WsNotification[_]]] =
|
||||
notificationsF._2._1
|
||||
|
||||
|
@ -468,13 +469,15 @@ class WebsocketTests extends BitcoinSServerMainBitcoindFixture {
|
|||
val peerAddr =
|
||||
InetSocketAddress.createUnresolved("127.0.0.1", NetworkUtil.randomPort())
|
||||
|
||||
exec(AcceptDLC(offer = offer,
|
||||
externalPayoutAddressOpt = None,
|
||||
externalChangeAddressOpt = None,
|
||||
peerAddr = peerAddr),
|
||||
cliConfig)
|
||||
|
||||
val acceptMsg = {
|
||||
AcceptDLC(offer = offer,
|
||||
externalPayoutAddressOpt = None,
|
||||
externalChangeAddressOpt = None,
|
||||
peerAddr = peerAddr)
|
||||
}
|
||||
for {
|
||||
_ <- setupF
|
||||
_ = ConsoleCli.exec(acceptMsg, cliConfig)
|
||||
_ <- AkkaUtil.nonBlockingSleep(500.millis)
|
||||
_ = promise.success(None)
|
||||
notifications <- walletNotificationsF
|
||||
|
|
Loading…
Add table
Reference in a new issue