status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-02-27 12:00:44 +00:00
Code Issues Projects Releases Wiki Activity

remove close from read/write methods

Browse Source
This commit is contained in:
Dmitriy Ryajov 2020-05-25 08:38:54 -06:00
parent 7a261ab103
commit d4f8680fe9
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
1 changed files with 3 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
libp2p/connection.nim
View File

@ -86,30 +86,18 @@ method readExactly*(s: Connection,
pbytes: pointer,
nbytes: int):
Future[void] {.async, gcsafe.} =
try:
await s.stream.readExactly(pbytes, nbytes)
except CatchableError as exc:
await s.close()
raise exc
await s.stream.readExactly(pbytes, nbytes)
method readOnce*(s: Connection,
pbytes: pointer,
nbytes: int):
Future[int] {.async, gcsafe.} =
try:
result = await s.stream.readOnce(pbytes, nbytes)
except CatchableError as exc:
await s.close()
raise exc
result = await s.stream.readOnce(pbytes, nbytes)
method write*(s: Connection,
msg: seq[byte]):
Future[void] {.async, gcsafe.} =
try:
await s.stream.write(msg)
except CatchableError as exc:
await s.close()
raise exc
await s.stream.write(msg)
method atEof*(s: Connection): bool {.inline.} =
if isNil(s.stream):