1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
package t::TestServerClient;
use v5.26;
use warnings;
use experimental 'signatures';
use Exporter 'import';
our @EXPORT = qw( make_serverclient );
use Scalar::Util qw( weaken );
sub make_serverclient ( $registry )
{
my $server = TestServer->new();
my $client = TestClient->new();
$server->registry( $registry );
weaken( $server->{client} = $client );
weaken( $client->{server} = $server );
$client->tangence_connected();
return ( $server, $client );
}
package TestServer;
use base qw( Tangence::Server );
sub new
{
return bless {}, shift;
}
sub tangence_write ( $self, $message )
{
$self->{client}->tangence_readfrom( $message );
length($message) == 0 or die "Client failed to read all Server wrote";
}
package TestClient;
use base qw( Tangence::Client );
sub new
{
my $self = bless {}, shift;
$self->identity( "testscript" );
$self->on_error( sub { die "Test failed early - $_[0]" } );
return $self;
}
sub tangence_write ( $self, $message )
{
$self->{server}->tangence_readfrom( $message );
length($message) == 0 or die "Server failed to read all Client wrote";
}
|
