lines-channel.p6

use v6.d;

use Concurrent::Channelify;

# say $*IN.lines⇒.no-thread;

# $*IN.^can('lines')[1].wrap(my method {
#     my $channel = Channel.new;
#     start {
#         for callsame() {
#             last if $channel.closed;
#             $channel.send($_)
#         }
#         LEAVE $channel.close unless $channel.closed;
#     }
#     $channel
# });

react {
    whenever signal(SIGINT) {
        say "Got signal";
        exit;
    }
    whenever $*IN.lines⇒ {
        say "got line";
    }
}