Changes

• Add Makefile for building the project
• Implement the StreamWritable
• Modify the Buffer initializer

Examples

Makefile

make [ all | Trevi | Lime | build | clean ]

• all: Download the Libuv from the github and compile. Then get Libuv.a for this project.
• Trevi: Compile the 'Trevi'.
• Lime: Compile the 'Lime'.
• build: Compile sources which you wrote.
• clean: Delete all files created while building.

Writable Stream

public class Writer: StreamWritable {
    var data = [Int8]()

    override func _write(chunk: Buffer, encoding: NSStringEncoding?, callback: writableCallback) {
        data.appendContentsOf(chunk.data)
        print("Adding: \(NSString(bytes: data, length: data.count, encoding: NSUTF8StringEncoding)!)")
        callback(nil)
    }
}

func onFinish() {
    print("finish!!")
}

let writer = Writer()
writer.on("finish", onFinish)

for item in ["Hello ", "World ", "on ", "SWIFT"] {
    writer.write(item)
}
writer.end("...!")

print(NSString(bytes: writer.data, length: writer.data.count, encoding: NSUTF8StringEncoding)!)

Result

Adding: Hello 
Adding: Hello World 
Adding: Hello World on 
Adding: Hello World on SWIFT
Adding: Hello World on SWIFT...!
finish!!
Hello World on SWIFT...!

Changes

• Implement the StreamWritable
• Modify the Buffer initializer

Examples

Writable Stream

public class Writer: StreamWritable {
    var data = [Int8]()

    override func _write(chunk: Buffer, encoding: NSStringEncoding?, callback: writableCallback) {
        data.appendContentsOf(chunk.data)
        print("Adding: \(NSString(bytes: data, length: data.count, encoding: NSUTF8StringEncoding)!)")
        callback(nil)
    }
}

func onFinish() {
    print("finish!!")
}

let writer = Writer()
writer.on("finish", onFinish)

for item in ["Hello ", "World ", "on ", "SWIFT"] {
    writer.write(item)
}
writer.end("...!")

print(NSString(bytes: writer.data, length: writer.data.count, encoding: NSUTF8StringEncoding)!)

Result

Adding: Hello 
Adding: Hello World 
Adding: Hello World on 
Adding: Hello World on SWIFT
Adding: Hello World on SWIFT...!
finish!!
Hello World on SWIFT...!

Changes

• Add classes for supporting 'Stream' (StreamReadable, StreamWritable)
• Add a function 'searchWithRegularExpression' for using regular expression simply.
• Change the File class formed utility(or helper) into that needs instantiation.
• Add the libuv libraries and headers.

Examples

Readable Stream

public class Counter: StreamReadable {
    private var _max = 10000
    private var _index = 1

    override func _read(n: Int) {
        let i = _index++
        if i > _max {
            push(nil)
        } else {
            push("\(i)")
        }
    }
}

var cnt = 1

func onData(data: AnyObject) {
    let tmp = data as! Buffer
    print("ondata \(cnt++) : \(tmp.data)")
}

func onEnd() {
    print("onend.")
}

let counter = Counter()
counter.on("data", onData)
counter.on("end", onEnd)

counter.read()

File reading

let file = ReadableFile(fileAtPath: path).open()
var buffer = [UInt8](count: 8, repeatedValue: 0)
let data = NSMutableData()

while file.status == .Open {
    let result: Int = file.read(&buffer, maxLength: buffer.count)
    data.appendBytes(buffer, length: result)
}

file.close()

File writing

let file = WritableFile(fileAtPath: "\(path).swift", option: O_CREAT|O_TRUNC).open()
file.write(UnsafePointer<UInt8>(code.dataUsingEncoding(NSUTF8StringEncoding)!.bytes), maxLength: code.characters.count)

WARNING

• Classes related File are not modified with Stream yet.

Changes

• Add a function 'searchWithRegularExpression' for using regular expression simply.
• Change the File class formed utility(or helper) into that needs instantiation.
• Add the libuv libraries and headers.

Examples

File reading

let file = Readable(fileAtPath: path).open()
var buffer = [UInt8](count: 8, repeatedValue: 0)
let data = NSMutableData()

while file.status == .Open {
    let result: Int = file.read(&buffer, maxLength: buffer.count)
    data.appendBytes(buffer, length: result)
}

file.close()

File writing

let file = Writable(fileAtPath: "\(path).swift", option: O_CREAT|O_TRUNC).open()
file.write(UnsafePointer<UInt8>(code.dataUsingEncoding(NSUTF8StringEncoding)!.bytes), maxLength: code.characters.count)

We are considering adding asynchronous event library because swift-corelibs-libdispatch is unstable for linux. In addition, we think libuv library has more powerful functions, and it makes our project advance like these projects (https://github.com/luvit/luvit / https://github.com/JuliaLang/julia).

Trevi is considering use work module to support multi thread while maintaining a event driven, non-blocking I/O model by Libuv. When stream module try read start, however, tcp read crushes like that nread is more than buffer size with out any errors.