| … | |
… | |
| 299 | } |
299 | } |
| 300 | |
300 | |
| 301 | $self->{s_framing} = $s_framing; |
301 | $self->{s_framing} = $s_framing; |
| 302 | |
302 | |
| 303 | $hdl->rbuf_max (undef); |
303 | $hdl->rbuf_max (undef); |
| 304 | my $queue = delete $self->{queue}; # we are connected |
|
|
| 305 | |
304 | |
| 306 | $self->{hdl}->rtimeout ($self->{remote_greeting}{timeout}); |
305 | $self->{hdl}->rtimeout ($self->{remote_greeting}{timeout}); |
| 307 | $self->{hdl}->wtimeout ($self->{timeout} - LATENCY); |
306 | $self->{hdl}->wtimeout ($self->{timeout} - LATENCY); |
| 308 | $self->{hdl}->on_wtimeout (sub { $self->send ([]) }); |
307 | $self->{hdl}->on_wtimeout (sub { $self->send ([]) }); |
|
|
308 | |
|
|
309 | my $queue = delete $self->{queue}; # we are connected |
| 309 | |
310 | |
| 310 | $self->connected; |
311 | $self->connected; |
| 311 | |
312 | |
| 312 | # send queued messages |
313 | # send queued messages |
| 313 | $self->send ($_) |
314 | $self->send ($_) |
