|
71
|
0 |
0 |
unless 'POE::Component::Client::TCP'->new(map({$_, $$stream{$_} || $$param{$_};} 'Alias', 'RemoteAddress', 'RemotePort', 'BindAddress', 'BindPort'), 'Filter', 'POE::Filter::Stream'->new, 'Connected', sub {
$_[3]{'server'}->put(grep({'???';
1;} join("\n", "GET $path HTTP/1.0", 'Icy-MetaData: 1', ('') x 2)));
}
, 'ServerInput', sub {
'???';
return unless my(%tag) = $_[10] =~ /Stream(\w+)='(.*?)';/g;
'???';
{
local $_[10] = \%tag;
$$param{'GetTags'}(@_) if ref $$param{'GetTags'} eq 'CODE';
} ;
}
, 'Disconnected', sub {
'???';
if ($$param{'Reconnect'}) {
'???';
$_[2]->delay('reconnect', $$param{'Reconnect'});
} ;
}
, 'ConnectError', sub {
warn "$$param{'Stream'} connect error: " . $_[12] . "\n";
if ($$param{'Reconnect'}) {
'???';
$_[2]->delay('reconnect', $$param{'Reconnect'});
} ;
}
, 'ServerError', sub {
warn "$$param{'Stream'} server error: " . $_[10] . "\n";
}
, 'SessionParams', ['options', {'trace', 0}]) |