#NEWLINE# def __init__( self , next_provider , sink_properties , global_properties ) : #NEWLINE# #INDENT# super ( ThriftMuxMessageSerializerSink , self ) . __init__ ( ) #NEWLINE# self . next_sink = next_provider . CreateSink ( global_properties ) #NEWLINE# self . _serializer = MessageSerializer ( global_properties [ SinkProperties . ServiceInterface ] ) #NEWLINE# self . _varz = self . Varz ( Source ( service = self [ SinkProperties . Label ] ) )