diff options
Diffstat (limited to '')
| -rw-r--r-- | stdlib/source/lux/world/net/tcp.jvm.lux | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/stdlib/source/lux/world/net/tcp.jvm.lux b/stdlib/source/lux/world/net/tcp.jvm.lux index de1d9ffef..bc8468c6b 100644 --- a/stdlib/source/lux/world/net/tcp.jvm.lux +++ b/stdlib/source/lux/world/net/tcp.jvm.lux @@ -64,39 +64,39 @@ (`` (for {(~~ (static host.jvm)) (as-is (def: (tcp socket) (-> Socket (Error (TCP IO))) - (do error.Monad<Error> + (do error.monad [input (Socket::getInputStream socket) output (Socket::getOutputStream socket)] (wrap (: (TCP IO) (structure (def: (read size) - (do io.Monad<Process> + (do (error.with-error io.monad) [#let [data (binary.create size)] bytes-read (InputStream::read data +0 (.int size) input)] (wrap [(.nat bytes-read) (integrity.taint data)]))) (def: (write data) - (do io.Monad<Process> + (do (error.with-error io.monad) [_ (OutputStream::write data +0 (.int (binary.size data)) output)] (Flushable::flush output))) (def: (close _) - (do io.Monad<Process> + (do (error.with-error io.monad) [_ (AutoCloseable::close input) _ (AutoCloseable::close output)] (AutoCloseable::close socket)))))))) (def: #export (client address port) (-> //.Address //.Port (IO (Error (TCP IO)))) - (do io.Monad<Process> + (do (error.with-error io.monad) [socket (Socket::new address (.int port))] (io.io (tcp socket)))) (def: #export (server port) (-> //.Port (IO (Error [(Promise Any) (frp.Channel (TCP IO))]))) - (do io.Monad<Process> + (do (error.with-error io.monad) [server (ServerSocket::new (.int port)) #let [close-signal (: (Promise Any) (promise #.None)) @@ -108,8 +108,8 @@ _ (: (Promise Any) (promise.future (loop [_ []] - (do io.Monad<IO> - [?client (do io.Monad<Process> + (do io.monad + [?client (do (error.with-error io.monad) [socket (ServerSocket::accept server)] (io.io (tcp socket)))] (case ?client |