#NEWLINE# def AsyncProcessRequest( self , sink_stack , msg , stream , headers ) : #NEWLINE# #INDENT# buf = StringIO ( ) #NEWLINE# headers = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# deadline = msg . properties . get ( Deadline . KEY ) #NEWLINE# if deadline : #NEWLINE# #INDENT# headers [ 'com.twitter.finagle.Deadline' ] = Deadline ( deadline ) #NEWLINE# #UNINDENT# try : #NEWLINE# #INDENT# self . _serializer . Marshal ( msg , buf , headers ) #NEWLINE# #UNINDENT# except Exception as ex : #NEWLINE# #INDENT# self . _varz . serialization_failures ( ) #NEWLINE# msg = MethodReturnMessage ( error = ex ) #NEWLINE# sink_stack . AsyncProcessResponseMessage ( msg ) #NEWLINE# return #NEWLINE# #UNINDENT# self . _varz . message_bytes_sent ( buf . tell ( ) ) #NEWLINE# sink_stack . Push ( self ) #NEWLINE# self . next_sink . AsyncProcessRequest ( sink_stack , msg , buf , headers )