ppackage Devel::Trace::Remote;
use strict;
use warnings;
use IO::Socket;
use threads;
use threads::shared;
use Thread::Queue;

my $connected :shared = 0;

my $Q = new Thread::Queue;

sub DB::DB {
    return unless $connected;
    $Q->enqueue( join ' : ', caller );
    return;
}

async {
    my $server = IO::Socket::INET->new(
        LocalHost => 'localhost:54321',
        Listen => 1,
        Reuse => 1,
    ) or die $!;
    $server->autoflush;
    while( my $client = $server->accept ) {
        $connected = 1;
        while( $_ = $Q->dequeue ) {
            print $client "$_\n\r" or last;
        };
        $connected = 0;
        $Q->dequeue while $Q->pending;
    }
}->detach;

1;