# Copyright (C) 2016-2018 all contributors # License: AGPL-3.0+ # Wrap a pipe or file for PSGI streaming response bodies and calls the # end callback when the object goes out-of-scope. # This depends on rpipe being _blocking_ on getline. package PublicInbox::GetlineBody; use strict; use warnings; sub new { my ($class, $rpipe, $end, $buf) = @_; bless { rpipe => $rpipe, end => $end, buf => $buf }, $class; } # close should always be called after getline returns undef, # but a client aborting a connection can ruin our day; so lets # hope our underlying PSGI server does not leak references, here. sub DESTROY { $_[0]->close } sub getline { my ($self) = @_; my $buf = delete $self->{buf}; # initial buffer defined $buf ? $buf : $self->{rpipe}->getline; } sub close { my ($self) = @_; my $rpipe = delete $self->{rpipe}; close $rpipe if $rpipe; my $end = delete $self->{end}; $end->() if $end; } 1;