Codibre/fluent-iterable

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export interface AsyncFlatJoinFunction<T> {
  /**
   * This operation flattens the whole informed path into a flat object.
   * Each informed param must be the name of a field in the path, the field being an iterable or not
   * If the name of a property appears twice in the path, the resulting object will have only the value of the first one

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export interface FlatJoinFunction<T> {
  /**
   * This operation flattens the whole informed path into a flat object.
   * Each informed param must be the name of a field in the path, the field being an iterable or not
   * If the name of a property appears twice in the path, the resulting object will have only the value of the first one

• Read up
  Read up

File flat-join-function.ts has 263 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import {
  tail,
  head,
  AsyncItemOrSelfType,
  FluentAsyncIterable,

Function getGroupingTopHit has 41 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function getGroupingTopHit<K, T, NewT = T>(
  distinct: AnyMapper<T> | Choose<NewT>,
  choose?: Choose<NewT>,
  mapper: Mapper<T, NewT> | keyof T = identity as any,
): KVGroupTransform<K, T, NewT> {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export interface DistinctByFunction<T> {
  /**
   * Returns distinct elements from the iterable from a certain list of projections<br>
   *   Examples:<br>
   *     * `fluent([{ a: 1, b: 2, c: 1}, { a: 1, b: 2, c: 2}]).distinct()` yields *{ a: 1, b: 2, c: 1 }*<br>

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export interface AsyncDistinctByFunction<T> {
  /**
   * Returns distinct elements from the iterable from a certain list of projections<br>
   *   Examples:<br>
   *     * `fluent([{ a: 1, b: 2, c: 1}, { a: 1, b: 2, c: 2}]).distinct()` yields *{ a: 1, b: 2, c: 1 }*<br>

• Read up
  Read up

Function distinctRecipe has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function distinctRecipe(ingredients: DistinctIngredients) {
  const ordered = orderedDistinctRecipe(ingredients);
  const choose = chooseDistinctRecipe(ingredients);
  const { filterOrAll, resolver } = ingredients;

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export interface KVGroupTransform<K, V, NewV = V> {
  (key: K, value: V, previous: NewV[]): Iterable<NewV> | undefined;
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export interface AsyncKVGroupTransform<K, V, NewV = V> {
  (key: K, value: V, previous: NewV[]): AnyIterable<NewV> | undefined;
}

• Read up
  Read up

Function groupRecipe has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function groupRecipe(ingredients: GroupIngredients) {
  const orderedGroup = orderedGroupRecipe(ingredients);
  const { reduceAndMap, resolver, iterate, forEach } = ingredients;
  return function <T>(
    this: AnyIterable<T>,

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export type ItemOrSelfType<T> = T extends string
  ? T
  : T extends Iterable<infer R>
  ? ItemOrSelfType<R>
  : T;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export type AsyncItemOrSelfType<T> = T extends string
  ? T
  : T extends AnyIterable<infer R>
  ? AsyncItemOrSelfType<R>
  : T;

• Read up
  Read up

Function distinct has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  return function distinct<T>(
    this: AnyIterable<T>,
    mappers: FunctionAnyMapper<any>[],
  ) {
    const { length } = mappers;

Similar blocks of code found in 2 locations. Consider refactoring.

Open

async function* iterateAllAsync<T>(a: AsyncIterable<AnyIterable<T>>) {
  for await (const it of a) {
    yield* it;
  }
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

function* iterateAll<T>(a: Iterable<Iterable<T>>) {
  for (const it of a) {
    yield* it;
  }
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export function desc<F>(f: F): F {
  return assureOrderDescending(
    (isValueType(f) ? { [valueTypeWrapper]: f } : f) as any,
  );
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

export function asc<F>(f: F): F {
  return assureOrder((isValueType(f) ? { [valueTypeWrapper]: f } : f) as any);
}

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  <R>(mapper: AsyncMapper<T, R>, choose: Choose<T>): FluentAsyncIterable<T>;

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

function distinctSyncRecipe(filterOrAll: Ingredient | ResolverIngredient) {
  return distinctByRecipe({
    ...basic,
    partition,
    filterOrAll,

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

function distinctAsyncRecipe(filterOrAll: Ingredient | ResolverIngredient) {
  return distinctRecipe({
    ...basicAsync,
    partition: partitionAsync,
    filterOrAll,

• Read up
  Read up