@SuppressWarnings("unchecked") @Test public void testFork() { Passthrough p1 = new Passthrough(1); Fork fork = new Fork(3); Connector.connect(p1, fork); Pushable push = p1.getPushableInput(0); QueueSink[] sinks = new QueueSink[3]; Queue<Object>[] queues = new Queue[3]; for (int i = 0; i < 3; i++) { sinks[i] = new QueueSink(1); Connector.connect(fork, i, sinks[i], 0); queues[i] = sinks[i].getQueue(0); } for (int k = 0; k < 2; k++) { for (int i = 0; i < 5; i++) { push.push(i); for (int j = 0; j < 2; j++) { Utilities.queueContains(i, queues[j]); } } } }
public Fork(int out_arity) { super(1, out_arity); }
Fork extends UniformProcessor { public Fork(int out_arity) { super(1, out_arity); } }
Fork extends UniformProcessor { public Fork(int out_arity) { super(1, out_arity); } Fork(int out_arity);  Fork(); }
Fork extends UniformProcessor { public Fork(int out_arity) { super(1, out_arity); } Fork(int out_arity);  Fork(); @Override Fork duplicate(boolean with_state); @SuppressWarnings("unchecked") void extendOutputArity(int out_arity); Object printState(); @Override Fork readState(Object o); }
Fork extends UniformProcessor { public Fork(int out_arity) { super(1, out_arity); } Fork(int out_arity);  Fork(); @Override Fork duplicate(boolean with_state); @SuppressWarnings("unchecked") void extendOutputArity(int out_arity); Object printState(); @Override Fork readState(Object o);  }