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

Open

function setupZapping(
  [graph, zapSpeed]: [dagre.graphlib.Graph, ZapSpeed],
): Diagram {
  const registry: ZapRegistry = new ZapRegistry();
  const sourceNodes: Array<string> = graph['sources']();

Function nodes has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function nodes(
  timestamp: number,
  speed: number,
  height: number,
  nodeCount: number

Function makeIsolateSink has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function makeIsolateSink<T extends VNode>(
  namespace: Array<Scope>
): IsolateSink<T> {
  return (sink, scope) => {
    if (scope === ':root') {

Function makeCallOnHistory has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

function makeCallOnHistory(history: History) {
  return function call(input: Narrow<HistoryInput>): void {
    if (input.type === 'push') {
      history.push({...input});
    }

• Read up
  Read up

Function renderCommonNode has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

function renderCommonNode(node: StreamGraphNode, zaps: Array<Zap>): VNode {
  const index = zaps.map(zap => zap.id).indexOf(node.id);
  const zap = index === -1 ? null : zaps[index];

  return svg.g([

• Read up
  Read up

Function get has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  public get(
    path: Array<T>,
    mkDefaultElement?: () => Payload,
    max?: number
  ): Payload | undefined {

• Read up
  Read up

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

Open

  public removeElement(element: Element, namespace?: Array<Scope>): void {
    if (namespace !== undefined) {
      this.virtualListeners.delete(namespace);
    }
    const toRemove: Array<[string, Element]> = [];

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

Open

  function processEvent() {
    if (paused) {
      return;
    }

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

Open

  return function animationFrames(): Stream<Frame> {
    const frame = {
      time: 0,
      delta: 16,
      normalizedDelta: 1,

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

Open

function BmiCalculator(sources: Sources): Sinks {
  const WeightSlider = isolate(LabeledSlider) as typeof LabeledSlider;
  const HeightSlider = isolate(LabeledSlider) as typeof LabeledSlider;

  const weightProps$ = xs.of({

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

Open

function main(sources: {DOM: DOMSource, HTTP: HTTPSource}) {
  const getRandomUser$ = sources.DOM.select('.get-random').events('click')
    .map(() => {
      const randomNum = Math.round(Math.random() * 9) + 1;
      return {

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

Open

function processEvent(args: any) {
  const {scheduler, done, currentTime, setTime, timeToRunTo} = args;
  const nextEvent = scheduler.peek();
  const outOfTime = nextEvent && timeToRunTo && nextEvent.time >= timeToRunTo;

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

Open

function makeDebounce(createOperator: () => OperatorArgs<any>) {
  const {schedule, currentTime} = createOperator();

  return function debounce(debounceInterval: number) {
    return function debounceOperator<T>(inputStream: Stream<T>): Stream<T> {

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

Open

function model(action$) {
  const initReducer$ = xs.of(function initReducer(prevState) {
    if (typeof prevState === 'undefined') {
      return {id: 0, removable: false, children: []}
    } else {

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

Open

function makeThrottle(createOperator: () => OperatorArgs<any>) {
  const {schedule, currentTime} = createOperator();

  return function throttle(period: number) {
    return function throttleOperator<T>(inputStream: Stream<T>): Stream<T> {

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

Open

      start(listener) {
        let lastValue: any = null;
        let emittedLastValue = true;
        const frame$ = xs.fromObservable(source.animationFrames());

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

Open

function showReport(status) {
  var headerShown = false;
  for (var package in status) {
    if (status.hasOwnProperty(package) && status[package].increment > 0) {
      if (!headerShown) {

Function matchObject has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

function matchObject(matcher: object, obj: object): boolean {
  const keys = Object.keys(matcher);
  const n = keys.length;
  for (let i = 0; i < n; i++) {
    const k = keys[i];

• Read up
  Read up

Function makeDebounceListener has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

function makeDebounceListener<T>(
  schedule: any,
  currentTime: () => number,
  debounceInterval: number,
  listener: any,

• Read up
  Read up

Function bubble has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  private bubble(
    eventType: string,
    elm: Element,
    rootElement: Element | undefined,
    event: CycleDOMEvent,

• Read up
  Read up