for chnanen

[catagits/HTTP-Body.git] / lib / HTTP / Body / OctetStream.pm

diff --git a/lib/HTTP/Body/OctetStream.pm b/lib/HTTP/Body/OctetStream.pm
new file mode 100644 (file)
index 0000000..f277c62
--- /dev/null
+++ b/lib/HTTP/Body/OctetStream.pm
@@ -0,0 +1,26 @@
+package HTTP::Body::Octetstream;
+
+use strict;
+use base 'HTTP::Body';
+use bytes;
+
+use File::Temp 0.14;
+
+sub spin {
+    my $self = shift;
+
+    unless ( $self->body ) {
+        $self->body( File::Temp->new );
+    }
+    
+    if ( my $length = length( $self->{buffer} ) ) {
+        $self->body->write( delete $self->{buffer}, $length );
+    }
+    
+    if ( $self->length == $self->content_length ) {
+        seek( $self->body, 0, 0 );
+        $self->state('done');
+    }
+}
+
+1;