diff options
author | Jesse Luehrs <doy@tozt.net> | 2012-09-28 23:37:03 -0500 |
---|---|---|
committer | Jesse Luehrs <doy@tozt.net> | 2012-09-28 23:43:29 -0500 |
commit | 378d39ae1a2cf3f6568e410a7844c2fa6dd12526 (patch) | |
tree | 5b2d73b8a0d09f54565e6026c5281afe6fe86ca3 /lib | |
parent | ed1144bec808d25ff8ebfa09a190e8ca3d5fee25 (diff) | |
download | web-request-378d39ae1a2cf3f6568e410a7844c2fa6dd12526.tar.gz web-request-378d39ae1a2cf3f6568e410a7844c2fa6dd12526.zip |
start adding support for streaming responses
Diffstat (limited to 'lib')
-rw-r--r-- | lib/Web/Response.pm | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/lib/Web/Response.pm b/lib/Web/Response.pm index c276724..6516021 100644 --- a/lib/Web/Response.pm +++ b/lib/Web/Response.pm @@ -63,6 +63,12 @@ has content => ( default => sub { [] }, ); +has streaming_response => ( + is => 'rw', + isa => 'CodeRef', + predicate => 'has_streaming_response', +); + has cookies => ( is => 'rw', isa => 'HashRef[Str|HashRef[Str]]', @@ -93,6 +99,11 @@ sub BUILDARGS { : ()), }; } + elsif (@_ == 1 && ref($_[0]) eq 'CODE') { + return { + streaming_response => $_[0], + }; + } else { return $class->SUPER::BUILDARGS(@_); } @@ -109,6 +120,9 @@ sub redirect { sub finalize { my $self = shift; + return $self->_finalize_streaming + if $self->has_streaming_response; + $self->_finalize_cookies; my $res = [ @@ -140,6 +154,15 @@ sub finalize { }); } +sub _finalize_streaming { + my $self = shift; + + # XXX cookies? + # XXX encoding? + + return $self->streaming_response; +} + sub _encode { my $self = shift; my ($content) = @_; |