lib/HTTP/Body/OctetStream.pm

   1 package HTTP::Body::Octetstream;
   2
   3 use strict;
   4 use base 'HTTP::Body';
   5 use bytes;
   6
   7 use File::Temp 0.14;
   8
   9 sub spin {
  10     my $self = shift;
  11
  12     unless ( $self->body ) {
  13         $self->body( File::Temp->new );
  14     }
  15
  16     if ( my $length = length( $self->{buffer} ) ) {
  17         $self->body->write( delete $self->{buffer}, $length );
  18     }
  19
  20     if ( $self->length == $self->content_length ) {
  21         seek( $self->body, 0, 0 );
  22         $self->state('done');
  23     }
  24 }
  25
  26 1;