Ekdohibs
/
zig
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

std/event/channel.zig: remove promise_symbol from suspend and use @handle(); 

Tracking Issue #1296 ;
master
kristopher tate 2018-07-29 17:12:33 +09:00
parent d3f628907a
commit 29057e5511
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
std/event/channel.zig
View File

@ -71,10 +71,10 @@ pub fn Channel(comptime T: type) type {
/// puts a data item in the channel. The promise completes when the value has been added to the /// puts a data item in the channel. The promise completes when the value has been added to the
/// buffer, or in the case of a zero size buffer, when the item has been retrieved by a getter. /// buffer, or in the case of a zero size buffer, when the item has been retrieved by a getter.
pub async fn put(self: *SelfChannel, data: T) void { pub async fn put(self: *SelfChannel, data: T) void {
suspend |handle| { suspend {
var my_tick_node = Loop.NextTickNode{ var my_tick_node = Loop.NextTickNode{
.next = undefined, .next = undefined,
.data = handle, .data = @handle(),
}; };
var queue_node = std.atomic.Queue(PutNode).Node{ var queue_node = std.atomic.Queue(PutNode).Node{
.data = PutNode{ .data = PutNode{
@ -96,10 +96,10 @@ pub fn Channel(comptime T: type) type {
// TODO integrate this function with named return values // TODO integrate this function with named return values
// so we can get rid of this extra result copy // so we can get rid of this extra result copy
var result: T = undefined; var result: T = undefined;
suspend |handle| { suspend {
var my_tick_node = Loop.NextTickNode{ var my_tick_node = Loop.NextTickNode{
.next = undefined, .next = undefined,
.data = handle, .data = @handle(),
}; };
var queue_node = std.atomic.Queue(GetNode).Node{ var queue_node = std.atomic.Queue(GetNode).Node{
.data = GetNode{ .data = GetNode{