monitor Daemon {
    has Listener $!listener = Listener.new;
    has Supplier $!send-data = Supplier.new;
    has %.stored-data is rw;

    method send-data(--> Supply) {
        supply {
            whenever $!listener.listen {
                my $address = %.stored-data{ $_<address> };
                my $type   = $address.WHO;

                if ($type ~~ 'Any') {
                    say 'address not found.';
                }
                elsif ($type !~~ 'Array') {
                    $address.emit($_);
                }
                elsif ($type ~~ 'Array') {
                    $address[0].emit($_);
                }
            }
        }
    }

    method new-address-amigo($extension) {
        my $supplier = Supplier.new;
        say 'supplying';
        whenever $supplier {
            say 'emiting to ' ~ $_<address>;
            say 'hmm ' ~ $supplier;
            say $_;
            say %.stored-data{ $extension };
            emit to-json $_;
        }

        %.stored-data.push: ( $extension => $supplier );
    }
}


_________________________________________________________________________________

my $message_text = Supplier.new;

get -> 'address-amigo' {
    web-socket -> $incoming, $close {
        supply {
            whenever $incoming -> $message {
                $daemon.new-address-amigo( await $message.body-text );
            }

            whenever $daemon.send-data {}
        }
    }
}