vacp2p/nim-libp2p
1
0
Fork 0
mirror of https://github.com/vacp2p/nim-libp2p.git synced 2025-03-02 17:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

close connection on chronos close

Browse Source
This commit is contained in:
Dmitriy Ryajov 2020-05-13 11:36:10 -06:00
parent e4b2018522
commit 40aef3ffa5
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/stream/chronosstream.nim
View File

@ -16,6 +16,12 @@ logScope:
type ChronosStream* = ref object of LPStream type ChronosStream* = ref object of LPStream
client: StreamTransport client: StreamTransport
proc onTransportClose(s: ChronosStream,
client: StreamTransport) {.async.} =
await client.join()
trace "Transport closed, closing connection"
await s.close()
proc newChronosStream*(client: StreamTransport): ChronosStream = proc newChronosStream*(client: StreamTransport): ChronosStream =
new result new result
result.client = client result.client = client