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
|
use lib 't/lib';
use TestHelp;
use Net::Stomp::Frame;
my ($s,$fh)=mkstomp_testsocket(timeout=>1);
my $str = "string\0with\0zeroes\0";
my $frame = Net::Stomp::Frame->new({
command=>'MESSAGE',
body=>$str,
headers=>{
'message-id'=>1,
'content-length'=>length($str),
},
});
my $frame_string = $frame->as_string;
my $time_out_next=0;
$fh->{to_read} = sub {
return if $time_out_next;
my $ret = substr($frame_string,0,2,'');
$time_out_next=1;
return $ret;
};
$s->select->{can_read} = sub {
return 1 unless $time_out_next;
$time_out_next=0;
return;
};
my $calls_needed = length($frame_string)/2;
for (1..$calls_needed-1) {
my $received = $s->receive_frame;
ok(!defined($received),'frame not received yet, time out');
}
my $received = $s->receive_frame;
cmp_deeply($received,$frame,'received and parsed');
done_testing;
|
