#NEWLINE# def pipe_writer( self , output_pipe ) : #NEWLINE# #INDENT# args = [ 'gzip' ] #NEWLINE# if ( self . compression_level is not None ) : #NEWLINE# #INDENT# args . append ( ( '-' + str ( int ( self . compression_level ) ) ) ) #NEWLINE# #UNINDENT# return OutputPipeProcessWrapper ( output_pipe , output_pipe )