UnixStream

(Fn [UnixStream] BufReader)

wraps this UnixStream in a BufReader for buffered I/O. Takes ownership of the stream — the BufReader will close it when deleted.

(match (UnixStream.connect "/tmp/my.sock")
  (Result.Success s)
    (let [br (UnixStream.buffered s)]
      (do
        (BufReader.write &br "hello\n")
        (ignore (BufReader.flush &br))
        (match (BufReader.read-line &br)
          (Result.Success line) (println* &line)
          _ ())
        (BufReader.delete br)))
  _ ())

(Fn [UnixStream] ())

closes the stream, releasing the file descriptor.

(Fn [(Ref String a)] (Result UnixStream String))

                        (connect path)
                    

connects to a Unix domain socket at the given path. Returns (Result UnixStream String).

(Fn [(Ref UnixStream a)] UnixStream)

(Fn [(Ref UnixStream a)] String)

returns the path of the remote peer socket.

(Fn [(Ref UnixStream a)] Int)

                        (poll-fd s)
                    

(Fn [(Ref UnixStream a)] (Result String b))

                        (read stream)
                    

reads up to 4096 bytes from the stream. Returns the data as a string, or an error. Returns an empty string on connection close.

(Fn [(Ref UnixStream a), (Ref (Array Byte) b)] (Result Int String))

                        (read-append stream buf)
                    

reads from the stream and appends to an existing byte buffer. Returns bytes read (0 = connection closed), or an error.

(Fn [(Ref UnixStream a)] (Result (Array Byte) b))

                        (read-bytes stream)
                    

reads up to 4096 bytes as a byte array.

(Fn [(Ref UnixStream a), (Ref String b)] (Result Int String))

                        (send stream msg)
                    

sends a string over the stream. Returns bytes sent or an error.

(Fn [(Ref UnixStream a), (Ref (Array Byte) b)] (Result Int String))

                        (send-bytes stream data)
                    

sends binary data over the stream. Returns bytes sent or an error.

(Fn [(Ref UnixStream a), Int] ())

sets read and write timeouts in seconds.

(Fn [(Ref UnixStream a), Int] ())

                        (shutdown stream how)
                    

shuts down the stream. 0 = reads, 1 = writes, 2 = both.

(Fn [(Ref UnixStream a), Int] ())

(Fn [(Ref UnixStream a)] ())

shuts down the read side of the stream.

(Fn [(Ref UnixStream a)] ())

shuts down the write side of the stream.

Macro

                        (with-stream name path :rest forms)
                    

connects, executes forms, then closes the stream.