Attempt #4 to fix Appveyor CI freeze.
This commit is contained in:
parent
708dcbd1a1
commit
236c685fb7
|
@ -131,7 +131,6 @@ type
|
||||||
topic*: string
|
topic*: string
|
||||||
handler*: P2PPubSubCallback
|
handler*: P2PPubSubCallback
|
||||||
transp*: StreamTransport
|
transp*: StreamTransport
|
||||||
loopFut*: Future[void]
|
|
||||||
|
|
||||||
PubSubMessage* = object
|
PubSubMessage* = object
|
||||||
peer*: PeerID
|
peer*: PeerID
|
||||||
|
@ -1283,7 +1282,7 @@ proc pubsubSubscribe*(api: DaemonAPI, topic: string,
|
||||||
ticket.topic = topic
|
ticket.topic = topic
|
||||||
ticket.handler = handler
|
ticket.handler = handler
|
||||||
ticket.transp = transp
|
ticket.transp = transp
|
||||||
ticket.loopFut = pubsubLoop(api, ticket)
|
asyncCheck pubsubLoop(api, ticket)
|
||||||
result = ticket
|
result = ticket
|
||||||
except:
|
except:
|
||||||
await api.closeConnection(transp)
|
await api.closeConnection(transp)
|
||||||
|
|
Loading…
Reference in New Issue