目录

AsyncChannelKit

CI

A simple implementation of an async channel for use with AsyncSequence and AsyncIterator which matches the same interface as Channel.

When the next() function is called it is expected to return a value asynchronusly for an async for loop. If the values are not created in response to calling this function these values will have to be provided somehow. This channel supports sending values which the next() can return.

In the unit tests, a channel is created which is also a sequence. The AyncIterator is a nested type. When the iterator is created it is given the same channel. Calling send on the channel will make new values available. When the next function is called it creates a continuation which will be matched to a value so it can be returned. Calling terminate will use a continuation to send nil which tells the for loop it is done.

All of the work done by the channel is done as an actor type so that it is thread-safe. Since it only uses features from the Swift Standard Library it should be usable on every platform which has Swift support.

关于
47.0 KB
邀请码
    Gitlink(确实开源)
  • 加入我们
  • 官网邮箱:gitlink@ccf.org.cn
  • QQ群
  • QQ群
  • 公众号
  • 公众号

版权所有:中国计算机学会技术支持:开源发展技术委员会
京ICP备13000930号-9 京公网安备 11010802032778号