I noticed that your readme doesn't have UDP socket support checked off. Is this something you're planning on adding? Definitely interested in utilizing this project, but UDP is a requirement for us.

Thanks!

thanks Venice u save my lot of time for writing code from scratch but there is not very much documentation and example of Venice

Documentation like what what class do ,what method do what about it what kind of parameter it takes what it return and a simple working example of it

it will be very helpful if you provide more documentation of Venice and Example of it

Thanks in advance :+1:

Following @Danappelxx suggestion, here are the updated docs. I heading to the GitBook now :)

As a side note, I updated .swift-version to 09-06.

Cheers

Hi,

Some examples the Venice Docs show that a Ticker emits timestamps on its channel (for time in Ticker().channel { … }). But in the current 0.12.0 Venice, a Ticker emits on Channel<Void>. I could not find a commit regarding this change.

As I think it’s nice to have, I’d like to re-add this : a Ticker will emit timestamp (based on C7.Time.now()) on its Channel<UInt64>.

Do you agree?

Right now second, millisecond, minute and hour are just hardcoded Int64 values. As alternative, I propose using Int extensions to make code slightly more readable and safe:

nap(1.second)
after(5.seconds) {
    // Do something
}

It can be achieved this way:

extension Int {
    var millisecond: Int64 {
        return Int64(self * 1)
    }
    var milliseconds: Int64 {
        return millisecond
    }
    var second: Int64 {
        return Int64(self * 1000)
    }
    var seconds: Int64 {
        return second
    }
    // and so on
}

Or nicer — with protocol:

public protocol IntervalConvertible {
    var millisecond: Int64 { get }
    var second: Int64 { get }
    // and so on
}

extension IntervalConvertible {
    public var milliseconds: Int64 {
        return millisecond
    }
    public var second: Int64 {
        return millisecond * 1000
    }
    public var seconds: Int64 {
        return second
    }
    // and so on
}

extension Int: IntervalConvertible {
    public var millisecond: Int64 {
        return Int64(self * 1)
    }
}

And even now can has it’s alternative:

extension Int64 {
    public var fromNow: Int64 {
        return Clibvenice.now() + self
    }
}

So one will be able to write:

let timer1 = Timer(deadline: now + 2 * second)
let timer2 = Timer(deadline: 2.seconds.fromNow)

Great work! I just wanted to point out that the output from the Fibonacci example shows 0,1,2,4,8,16... (2^N) instead of 1,1,2,3,5,8... as one would expect.

Summary

• Added extra test scenarios for better code coverage for FileDescriptor class.
• Changed a small error checking in init that was unnecessary since the file descriptor was already tested few lines before.

Looks like there's an issue with Venice 0.1.1 and compatibility with libvenice 0.1.0. I checked the brew formula and didn't see an update. Here's output from my console.

Compiling Swift Module 'Venice' (21 sources)
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Channel.swift:47:48: error: extra argument in call
        self.channel = mill_chmake(bufferSize, "Channel init")
                                               ^~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Channel.swift:51:31: error: extra argument in call
        mill_chclose(channel, "Channel deinit")
                              ^~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Channel.swift:69:34: error: extra argument in call
            mill_chdone(channel, "Channel close")
                                 ^~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Channel.swift:77:31: error: extra argument in call
            mill_chs(channel, "Channel send")
                              ^~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Channel.swift:94:27: error: extra argument in call
        mill_chr(channel, "Channel receive")
                          ^~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:45:8: error: extra argument in call
    }, "co")
       ^~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:53:8: error: extra argument in call
    }, "co")
       ^~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:66:21: error: missing argument for parameter #3 in call
    return goprepare(Int32(stackCount), stackSize)
                    ^
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:71:33: error: extra argument in call
    mill_msleep(now + duration, "nap")
                                ^~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:76:27: error: extra argument in call
    mill_msleep(deadline, "wakeUp")
                          ^~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:81:16: error: argument passed to call that takes no arguments
    mill_yield("yield")
              ~^~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:86:12: error: use of unresolved identifier 'mfork'
    return mfork()
           ^~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Co.swift:91:16: error: use of unresolved identifier 'mill_number_of_cores'
    return Int(mill_number_of_cores())
               ^~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:66:48: error: extra argument in call
        self.channel = mill_chmake(bufferSize, "FallibleChannel init")
                                               ^~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:70:31: error: extra argument in call
        mill_chclose(channel, "FallibleChannel deinit")
                              ^~~~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:88:34: error: extra argument in call
            mill_chdone(channel, "FallibleChannel close")
                                 ^~~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:96:31: error: extra argument in call
            mill_chs(channel, "FallibleChannel sendResult")
                              ^~~~~~~~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:105:31: error: extra argument in call
            mill_chs(channel, "FallibleChannel send")
                              ^~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:123:31: error: extra argument in call
            mill_chs(channel, "FallibleChannel send")
                              ^~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:141:27: error: extra argument in call
        mill_chr(channel, "FallibleChannel receive")
                          ^~~~~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/FallibleChannel.swift:157:27: error: extra argument in call
        mill_chr(channel, "FallibleChannel receiveResult")
                          ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Poller.swift:53:79: error: extra argument in call
    let event = mill_fdwait(fileDescriptor, Int32(events.rawValue), deadline, "pollFileDescriptor")
                                                                              ^~~~~~~~~~~~~~~~~~~~
/Users/ssoper/workspace/Runabout/Packages/Venice-0.1.1/Source/Select.swift:340:22: error: argument passed to call that takes no arguments
    mill_choose_init("select")
                    ~^~~~~~~~~
<unknown>:0: error: build had 1 command failures
swift-build: exit(1): ["/Library/Developer/Toolchains/swift-2.2-SNAPSHOT-2015-12-18-a.xctoolchain/usr/bin/swift-build-tool", "-f", "/Users/ssoper/workspace/Runabout/.build/debug/Venice.o/llbuild.yaml"]

Problem

The burst example in README got "Binary operator '<-' cannot be applied to operands of type 'Channel<Int>' and 'Int64'" because the type mismatch of the Int channel and now and time generated from Ticker channel as Int64.

let burstyLimiter = Channel<Int>(bufferSize: 3)

for _ in 0 ..< 3 {
    burstyLimiter <- now // Compiler error here. now is Int64.
}

co {
    for time in Ticker(period: 200 * millisecond).channel {
        burstyLimiter <- time // Compiler error here. time is Int64.
    }
}

Fix

Changed the type of the channel to Int64.

Environment

• Venice 0.9
• Xcode 7.1.1
• OS X 10.11.1

Is there a better way to a achieve the following? Perhaps will only one channel? But then, I need to close it to know when all coroutines have finished. Not sure how to improve this.

import Venice

var numbers: [Int] = []

for i in 2...100 {
    numbers.append(i)
}

var primes: [Channel<Int>] = []

for number in numbers {
    let prime = Channel<Int>()
    primes.append(prime)

    co {
        for i in 2..<number {
            if number % i == 0 {
                prime.close()
                return
            }
        }

        prime <- number
        prime.close()
    }
}

for prime in primes.flatMap({ <-$0 }) {
    print("\(prime) is prime")
}

Summary

Added the ability to a coroutine to call a custom handle when it is cancelled or terminated. It is important to give the ability to a programmer to respond to a coroutine cancellation/end of execution since it can add a lot of flexibility.

Design decisions

The handle is a simples closure that receives as parameter a boolean value. If true, the coroutine was cancelled. Otherwise, it is terminating gracefully.

The handle will be called immediately before the coroutine handle is called. So, the coroutine have the ability to end gracefully.

Use this template for simple enhancements that do not need a fully-fledged proposal.

How to cooperate with ObjC code?

Description

Is there a way to cooperate with ObjC code? For example , my project is mixed with ObjC code and Swift code, How can this 2 languages use this library and the API supports each other?

Is there any suggestion? Thanks a lot!

This implements several discussed changes to Venice:

1. Bundles libdill directly, this avoids the need to use an apt/brew package
2. Adds coroutine local storage support
3. Refactors coroutines so they manage their own lifetime and clean up automatically