39 lines
1.1 KiB
Text
39 lines
1.1 KiB
Text
"#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.readline {
|
|
def id =id
|
|
def byte 0 =byte
|
|
def array 0 anew =array
|
|
def tmparray 0 anew =tmparray
|
|
def i 1 neg =i
|
|
while { ( i 1 + =i ) ( byte 10 eq not ) } {
|
|
id STREAM.read stream =byte
|
|
array ( ( array alen 1 + anew ) dup =tmparray ) 0 0 ( array alen ) acopy =array
|
|
array dup alen 1 - byte _char aput
|
|
}
|
|
array ( ( array alen 1 - anew ) dup =tmparray 0 0 ) ( tmparray alen ) acopy _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
|
|
}
|
|
}
|