I have this code below, where I am appending to a list in a channel, but sending -1 won't shutdown, and the app never exits. What am I doing wrong?
require channels
append(msg) =>
-1 : @shutdown
@print : print(mem[@values])
* | mem[@values] == Nothing : mem[@values] = [msg]
| else : push(mem[@values], msg)
where
mem : channel_memory()
main ->
channel(@bucket, append, { @serialize: true}),
@bucket.send(i) for i in [1..10],
@bucket.send(@print),
@bucket.send(-1)