User defined pipe and redirection operators: Difference between revisions
Content added Content deleted
| Line 574: | Line 574: | ||
end |
end |
||
function grep(inchan::Channel, target) |
function grep(inchan::Channel, target, outchan = channelstream()) |
||
outchan = channelstream() |
|||
@async begin |
@async begin |
||
try |
try |
||
| Line 627: | Line 626: | ||
end |
end |
||
function Sort(inchan) |
function Sort(inchan, outchan = channelstream()) |
||
outchan = channelstream() |
|||
buffer = String[] |
buffer = String[] |
||
try |
try |
||
| Line 646: | Line 644: | ||
Sort() = (chan) -> Sort(chan) |
Sort() = (chan) -> Sort(chan) |
||
function uniq(inchan) |
function uniq(inchan, outchan = channelstream()) |
||
outchan = channelstream() |
|||
alreadyseen = Set{String}() |
alreadyseen = Set{String}() |
||
@async begin |
@async begin |
||