File use-observable-get-state.ts has 357 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import { useDebugValue } from "react";
import { Observable } from "rxjs";
import { map } from "rxjs/operators";
import { useObservableState } from "./use-observable-state";
import { useObservable } from "./use-observable";

File concurrent-mode.spec.tsx has 281 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/* eslint-disable @typescript-eslint/no-unsafe-assignment */
/* eslint-disable @typescript-eslint/no-unsafe-return */
import * as RxType from "rxjs";

let Scheduler: import("./utils").Scheduler;

Function useObservableEagerState has 65 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function useObservableEagerState<TState>(
  state$: Observable<TState>
): TState {
  const forceUpdate = useForceUpdate();

Function constructor has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

  public constructor(
    input$: Observable<TInput>,
    isSuccess?: TInput extends TOutput
      ? (value: TInput) => boolean
      : (value: TInput) => value is TOutput

• Read up
  Read up

Function constructor has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  public constructor(
    input$: Observable<TInput>,
    isSuccess?: TInput extends TOutput
      ? (value: TInput) => boolean
      : (value: TInput) => value is TOutput

Function useSubscriptionInternal has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function useSubscriptionInternal<TInput>(
  useCustomEffect: typeof useEffect,
  args: Args<TInput>
): MutableRefObject<Subscription | undefined> {
  const argsRef = useRef(args);

Function ObservableValueDescendant has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export const ObservableValueDescendant = () => {
  const num$ = useContext(ObservableValueContext);

  // If you need to transform(pipe) the Observable
  // you should list it as dependency since it may change over time.

Function fakePostsXHR has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function fakePostsXHR(id: string): Promise<Posts> {
  console.log("fetch post...");
  await timer(3000 * Math.random());
  console.log("fetched post");
  switch (id) {

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

Open

export function useObservableStateInternal<TState, TInput = TState>(
  useSubscription: typeof useSubscriptionType,
  state$OrInit:
    | Observable<TState>
    | ((

Function fromNow has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

function fromNow(diff: number): string {
  const minute = (diff / 60) | 0;
  const second = diff - minute * 60;
  const mstr =
    minute < 1 ? "" : minute === 1 ? `a minute and ` : `${minute} minutes and `;

• Read up
  Read up