def streaming_instance(d: ApiDefinition, m: Callable):
    (callback_type, is_wrapper) = GeneratorUtils.callback_type(d, m)
    if is_wrapper:
        return f'{callback_type}({forward_method_parameters_dict_style(GeneratorUtils.data_class_members(d, [m], True))})'
    else:
        return GeneratorUtils.data_class_members(d, [m], False)[0].name
def streaming_instance(d: ApiDefinition, m: Callable):
    (callback_type, is_wrapper) = GeneratorUtils.callback_type(d, m)
    if is_wrapper:
        return f'{callback_type}({forward_method_parameters_dict_style(GeneratorUtils.data_class_members(d, [m], True))})'
    else:
        return GeneratorUtils.data_class_members(d, [m], False)[0].name