def __init__(self, func, use_keys_not_values=False):
        """
        Stream broadcaster from stream

        :param func: The function to be applied to the value in each document
        """
        super(StreamBroadcasterFromStream, self).__init__(func=func, use_keys_not_values=use_keys_not_values)
def __init__ ( self , func , use_keys_not_values = False ) : super ( StreamBroadcasterFromStream , self ) . __init__ ( func = func , use_keys_not_values = use_keys_not_values )
Stream broadcaster from stream

        :param func: The function to be applied to the value in each document