basic.DuplicateNoState Class Reference

Duplicating processors without preserving their state. More...

Static Public Member Functions
static void	main (String[] args)

Detailed Description

Duplicating processors without preserving their state.

Author

Sylvain Hallé Easy

Definition at line 33 of file DuplicateNoState.java.

Member Function Documentation

main()

static void basic.DuplicateNoState.main ( String []  args )

static

We first create a cumulative processor and a simple GroupProcessor

Definition at line 35 of file DuplicateNoState.java.

  {
    /// We first create a cumulative processor and a simple GroupProcessor
    Cumulate sum1 = new Cumulate(
        new CumulativeFunction<Number>(Numbers.addition));
    Connector.connect(sum1, new Print()
        .setPrefix("sum1: ").setSeparator("\n"));

    // We then feed a few events to each of them
    Pushable p_sum1 = sum1.getPushableInput();
    p_sum1.push(3).push(1).push(4);
    ///
    
    //* Let us now duplicate sum1 and push events to the copy
    Cumulate sum2 = (Cumulate) sum1.duplicate();
    Connector.connect(sum2, new Print()
        .setPrefix("sum2: ").setSeparator("\n"));
    Pushable p_sum2 = sum2.getPushableInput();
    p_sum2.push(2).push(7).push(1);
    //*
  }

---

The documentation for this class was generated from the following file:

• Source/src/basic/DuplicateNoState.java