fixes broken test

.gitignore

@@ -1,2 +1,2 @@
 nimcache/
-
+*.exe

faststreams/inputs.nim

@@ -789,7 +789,7 @@ proc readInto*(s: InputStream, target: var openarray[byte]): bool =
   s.readIntoEx(target) == target.len
 
 template readIntoEx*(sp: AsyncInputStream, dst: var openarray[byte]): int =
-  let s = sp
+  let s = InputStream(sp)
   # BEWARE! `openArrayToPair` here is needed to avoid
   # double evaluation of the `dst` expression:
   let (dstAddr, dstLen) = openArrayToPair(dst)
@@ -806,7 +806,7 @@ template readInto*(sp: AsyncInputStream, dst: var openarray[byte]): bool =
   ## the expression will complete immediately.
   ## Otherwise, it will await more bytes to become available.
 
-  let s = sp
+  let s = InputStream(sp)
   # BEWARE! `openArrayToPair` here is needed to avoid
   # double evaluation of the `dst` expression:
   let (dstAddr, dstLen) = openArrayToPair(dst)

tests/test_pipelines.nim

@@ -38,6 +38,15 @@ template timeit(timerVar: var Nanos, code: untyped) =
   code
   timerVar = int(getTicks() - t0) div 1000000
 
+proc getOutput(sp: AsyncInputStream, T: type string): Future[string] {.async.} =
+  # this proc is a quick hack to let the test pass
+  # do not use it in production code
+  let size = sp.totalUnconsumedBytes()
+  if size > 0:
+    var data = newSeq[byte](size)
+    discard sp.readinto(data)
+    result = cast[string](data)
+
 procSuite "pipelines":
   let loremIpsum = """
     Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod
@@ -117,4 +126,3 @@ procSuite "pipelines":
     let fsAsyncres = await f
 
     check fsAsyncRes == toUpperAscii(inputText)
-