| … | … | ||
|---|---|---|---|
| 1190 | my $type = shift; | 1190 | my $type = shift; |
| 1191 | 1191 | ||
| 1192 | $cb = ($RH{$type} or Carp::croak "unsupported type passed to AnyEvent::Handle::unshift_read") | 1192 | $cb = ($RH{$type} or Carp::croak "unsupported type passed to AnyEvent::Handle::unshift_read") |
| 1193 | ->($self, $cb, @_); | 1193 | ->($self, $cb, @_); |
| 1194 | } | 1194 | } |
| 1195 | |||
| 1196 | 1195 | ||
| 1197 | unshift @{ $self->{_queue} }, $cb; | 1196 | unshift @{ $self->{_queue} }, $cb; |
| 1198 | $self->_drain_rbuf; | 1197 | $self->_drain_rbuf; |
| 1199 | } | 1198 | } |
| 1200 | 1199 |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |