cyclejs/cycle-core

Function timeDriver has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function timeDriver(sink: any): any {
  let time = 0;
  const frameCallbacks: Array<any> = [];
  const scheduler = makeScheduler();

Function intent has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function intent(domSource, timeSource) {
  const UP_KEYCODE = 38
  const DOWN_KEYCODE = 40
  const ENTER_KEYCODE = 13
  const TAB_KEYCODE = 9

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

Open

  const changeColorReducer$ = action$
    .filter(a => a.type === 'CHANGE_COLOR')
    .map(action => function changeColorReducer(oldState) {
      return {color: action.payload, width: oldState.width};
    });

• Read up
  Read up

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

Open

  const changeWidthReducer$ = action$
    .filter(a => a.type === 'CHANGE_WIDTH')
    .map(action => function changeWidthReducer(oldState) {
      return {color: oldState.color, width: action.payload};
    });

• Read up
  Read up

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

Open

export function makeHashHistoryDriver(
  options?: HashHistoryOptions
): HistoryDriver {
  const history = createHashHistory(options);
  return function hashHistoryDriver(sink$: Stream<HistoryInput | string>) {

• Read up
  Read up

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

Open

export function makeServerHistoryDriver(
  options?: MemoryHistoryOptions
): HistoryDriver {
  const history = createMemoryHistory(options);
  return function serverHistoryDriver(sink$: Stream<HistoryInput | string>) {

• Read up
  Read up

Function renderNodeLabel has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function renderNodeLabel(node: StreamGraphNode, zap: Zap | null, style: string): VNode {
  let label = '';
  if (zap) {
    // MUTATION!
    if (Array.isArray(zap.value)) {

Function reducers has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function reducers(actions) {
  const moveHighlightReducer$ = actions.moveHighlight$
    .map(delta => function moveHighlightReducer(state) {
      const suggestions = state.get('suggestions')
      const wrapAround = x => (x + suggestions.length) % suggestions.length

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

Open

function makeThrottleAnimation(
  timeSource: any,
  schedule: any,
  currentTime: () => number
) {

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

Open

function makeDiagram(
  schedule: any,
  currentTime: () => number,
  interval: number,
  setMaxTime: any

Function renderCommonNode has 40 lines of code (exceeds 25 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([

Function setupNonBubblingListener has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private setupNonBubblingListener(
    input: NonBubblingMeta
  ): void {
    const [_, eventType, elementFinder, destination] = input;
    if (!this.origin) {

Function diagram has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  return function diagram(diagramString: string, values = {}): Stream<any> {
    const characters = diagramString.split('');
    const stream = xs.create();
    function valueFor(character: string) {
      if (character in values) {

Function throttleAnimation has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  return function throttleAnimation<T>(inputStream: Stream<T>): Stream<T> {
    const source = timeSource();
    const stream = xs.fromObservable(inputStream);
    let animationListener: any = null;

Function replicateMany has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function replicateMany<Si extends any>(
  sinks: Si,
  sinkProxies: SinkProxies<Si>
): DisposeFunction {
  const scheduleMicrotask = quicktask();

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

Open

  public _n(inst: InternalInstances<Si>): void {
    this.inst = inst;
    const arrSinks = inst.arr;
    const ils = this.ils;
    const out = this.out;

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

Open

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

  return function periodic(period: number): Stream<number> {
    let stopped = false;

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

Open

function makeClickListener(push: (p: string) => void) {
  return function clickListener(event: MouseEvent) {
    if (which(event) !== 1) {
      return;
    }

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

Open

function runUpdateChangelogs() {
  packagesWithChangelog
    .filter(function (package) {
      if (typeof argPackage === 'string' && argPackage.length > 0) {
        return argPackage === package;

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

Open

function main(sources: Sources): Sinks {
  const firstName$ = sources.DOM
    .select('.first')
    .events('input')
    .map(ev => (ev.target as HTMLInputElement).value)