isbpl/stream.isbpl

"#iota.isbpl" include

native stream

def STREAM.create.file.in riota =STREAM.create.file.in
def STREAM.create.file.out iota =STREAM.create.file.out
def STREAM.create.socket   iota =STREAM.create.socket
def STREAM.close           iota =STREAM.close
def STREAM.read            iota =STREAM.read
def STREAM.write           iota =STREAM.write

"not implemented:" #
    def STREAM.aread           iota =STREAM.aread
    def STREAM.awrite          iota =STREAM.awrite

def STREAM.create.server iota =STREAM.create.server

func STREAM.stdin {
    getos strlowercase "win" astartswith dup if { "conIN$" 2 stop } not if { "/dev/stdin" 2 stop }
}

func stream.readline {
    def id =id
    def byte 0 =byte
    def array 0 anew =array
    def tmparray 0 anew =tmparray
    def i 1 neg =i
    id STREAM.read stream =byte
    byte -1 eq if {
        -1
        2 stop
    }
    while { ( i 1 + =i ) ( byte 10 eq not ) } {
        array ( ( array alen 1 + anew ) dup =tmparray ) 0 0 ( array alen ) acopy =array
        array dup alen 1 - byte _char aput
        id STREAM.read stream =byte
    }
    array alen 0 eq if {
        array _string
        2 stop
    }
    array array alen 1 - aget _int 13 eq if {
        def arr array alen 1 - anew =arr
        array arr 0 0 arr alen acopy =array
    }
    array _string
}

func stream.write {
    def id =id
    def str _array =str 
    def i 1 neg =i
    while { ( i 1 + =i ) ( i str alen lt ) } {
        str i aget id STREAM.write stream
    }
}