basic.DuplicateGroup 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 35 of file DuplicateGroup.java.

Member Function Documentation

main()

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

static

We first create a GroupProcessor

Let us clone gp1 and connect it to a new source

Definition at line 37 of file DuplicateGroup.java.

  {
    /// We first create a GroupProcessor
    QueueSource source1 = new QueueSource().setEvents(3, 1, 4, 1, 5);
    GroupProcessor gp1 = new GroupProcessor(1, 1);
    {
      Stutter st = new Stutter(2);
      Cumulate sum = new Cumulate(
          new CumulativeFunction<Number>(Numbers.addition));
      Connector.connect(st, sum);
      gp1.addProcessors(st, sum);
      gp1.associateInput(0, st, 0);
      gp1.associateOutput(0, sum, 0);
    }
    Connector.connect(source1, gp1);
    
    // We pull one event from gp1
    Pullable p_gp1 = gp1.getPullableOutput();
    System.out.println(p_gp1.pull());
    ///

    //! Let us clone gp1 and connect it to a new source
    QueueSource source2 = new QueueSource().setEvents(2, 7, 1, 8);
    GroupProcessor gp2 = gp1.duplicate(true);
    Connector.connect(source2, gp2);
    Pullable p_gp2 = gp2.getPullableOutput();
    System.out.println(p_gp2.pull());
    //!
  }

---

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

• Source/src/basic/DuplicateGroup.java