@@ -1082,6 +1082,22 @@ proc newAsyncStreamReader*(tsource: StreamTransport): AsyncStreamReader =
1082
1082
res.init(tsource)
1083
1083
res
1084
1084
1085
+ proc newAsyncStreamReader*[T](rsource: AsyncStreamReader,
1086
+ udata: ref T): AsyncStreamReader =
1087
+ ## Create copy of AsyncStreamReader object ``rsource``.
1088
+ ##
1089
+ ## ``udata`` - user object which will be associated with new AsyncStreamReader
1090
+ ## object.
1091
+ var res = AsyncStreamReader()
1092
+ res.init(rsource, udata)
1093
+ res
1094
+
1095
+ proc newAsyncStreamReader*(rsource: AsyncStreamReader): AsyncStreamReader =
1096
+ ## Create copy of AsyncStreamReader object ``rsource``.
1097
+ var res = AsyncStreamReader()
1098
+ res.init(rsource)
1099
+ res
1100
+
1085
1101
proc newAsyncStreamWriter*[T](wsource: AsyncStreamWriter,
1086
1102
loop: StreamWriterLoop,
1087
1103
queueSize = AsyncStreamDefaultQueueSize,
@@ -1147,22 +1163,6 @@ proc newAsyncStreamWriter*(wsource: AsyncStreamWriter): AsyncStreamWriter =
1147
1163
res.init(wsource)
1148
1164
res
1149
1165
1150
- proc newAsyncStreamReader*[T](rsource: AsyncStreamWriter,
1151
- udata: ref T): AsyncStreamWriter =
1152
- ## Create copy of AsyncStreamReader object ``rsource``.
1153
- ##
1154
- ## ``udata`` - user object which will be associated with new AsyncStreamReader
1155
- ## object.
1156
- var res = AsyncStreamReader()
1157
- res.init(rsource, udata)
1158
- res
1159
-
1160
- proc newAsyncStreamReader*(rsource: AsyncStreamReader): AsyncStreamReader =
1161
- ## Create copy of AsyncStreamReader object ``rsource``.
1162
- var res = AsyncStreamReader()
1163
- res.init(rsource)
1164
- res
1165
-
1166
1166
proc getUserData*[T](rw: AsyncStreamRW): T {.inline.} =
1167
1167
## Obtain user data associated with AsyncStreamReader or AsyncStreamWriter
1168
1168
## object ``rw``.
0 commit comments