Skip to content

Commit 7e43db8

Browse files
committed
Remove code that now exists in gren-lang/core
1 parent d5b651c commit 7e43db8

1 file changed

Lines changed: 1 addition & 32 deletions

File tree

src/Stream/Extra.gren

Lines changed: 1 addition & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -7,35 +7,4 @@ import Task exposing (Task)
77

88
consumeString : Stream.Readable String -> Task Stream.Error String
99
consumeString stream =
10-
readUntilClosed (\chunk result -> Ok (result ++ chunk)) "" stream
11-
12-
13-
{- Below is copied from gren-lang/core -}
14-
15-
readUntilClosed : (a -> b -> Result String b) -> b -> Stream.Readable a -> Task Stream.Error b
16-
readUntilClosed stepFn init stream =
17-
readUntilClosedHelper stepFn init stream
18-
19-
20-
readUntilClosedHelper : (a -> b -> Result String b) -> b -> Stream.Readable a -> Task Stream.Error b
21-
readUntilClosedHelper stepFn oldAcc stream =
22-
Stream.read stream
23-
|> Task.andThen
24-
(\newPart ->
25-
when stepFn newPart oldAcc is
26-
Ok newAcc ->
27-
readUntilClosedHelper stepFn newAcc stream
28-
29-
Err reason ->
30-
Stream.cancelReadable reason stream
31-
|> Task.andThen (\_ -> Task.fail (Stream.Cancelled reason))
32-
)
33-
|> Task.onError
34-
(\err ->
35-
when err is
36-
Stream.Closed ->
37-
Task.succeed oldAcc
38-
39-
_ ->
40-
Task.fail err
41-
)
10+
Stream.readUntilClosed (\chunk result -> Ok (result ++ chunk)) "" stream

0 commit comments

Comments
 (0)