diff options
Diffstat (limited to 'stdlib/source/library/lux/world/net/http/client.lux')
| -rw-r--r-- | stdlib/source/library/lux/world/net/http/client.lux | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/stdlib/source/library/lux/world/net/http/client.lux b/stdlib/source/library/lux/world/net/http/client.lux index 2a160d0fd..02cc6ed91 100644 --- a/stdlib/source/library/lux/world/net/http/client.lux +++ b/stdlib/source/library/lux/world/net/http/client.lux @@ -114,7 +114,7 @@ (case> [_ 0] (do (try.with io.monad) [_ (java/lang/AutoCloseable::close input)] - (wrap ..empty_body)) + (in ..empty_body)) [partial? buffer_size] (let [buffer (binary.create buffer_size)] @@ -126,10 +126,10 @@ (case bytes_read -1 (do ! [_ (java/lang/AutoCloseable::close input)] - (wrap [(.nat so_far) buffer])) + (in [(.nat so_far) buffer])) +0 (recur so_far) _ (if (i.= remaining bytes_read) - (wrap [buffer_size buffer]) + (in [buffer_size buffer]) (recur (i.+ bytes_read so_far)))))) (loop [so_far +0 output (\ binary.monoid identity)] @@ -140,13 +140,13 @@ -1 (do ! [_ (java/lang/AutoCloseable::close input)] (case so_far - +0 (wrap (..body_of output)) + +0 (in (..body_of output)) _ (|> buffer (binary.slice 0 (.nat so_far)) (\ try.functor map (|>> (\ binary.monoid compose output) ..body_of)) - (\ io.monad wrap)))) + (\ io.monad in)))) +0 (recur so_far output) _ (if (i.= remaining bytes_read) (recur +0 @@ -168,7 +168,7 @@ (dictionary.put name (maybe.default "" ?value) headers))) #.None - (wrap headers))))) + (in headers))))) (implementation: #export default (Client IO) @@ -190,18 +190,18 @@ _ (java/io/OutputStream::write data stream) _ (java/io/OutputStream::flush stream) _ (java/lang/AutoCloseable::close stream)] - (wrap [])) + (in [])) #.None - (wrap [])) + (in [])) status (java/net/HttpURLConnection::getResponseCode connection) headers (..default_headers connection) input (|> connection java/net/URLConnection::getInputStream (\ ! map (|>> java/io/BufferedInputStream::new)))] - (wrap [(.nat status) - {#//.headers headers - #//.body (..default_body input)}]))))))] + (in [(.nat status) + {#//.headers headers + #//.body (..default_body input)}]))))))] (for {@.old (as_is <jvm>) @.jvm (as_is <jvm>)} (as_is))) |