Sha256: 28d3e06a12c5571e43dea717d2384e51a9ed455780c442502f946e43b4675dd2
Contents?: true
Size: 1.02 KB
Versions: 11
Compression:
Stored size: 1.02 KB
Contents
package com.xnlogic.pacer.pipes;
import static org.junit.Assert.*;
import org.junit.Test;
import com.tinkerpop.pipes.Pipe;
import com.tinkerpop.pipes.IdentityPipe;
import java.util.Arrays;
import java.util.List;
import com.xnlogic.pacer.pipes.BlackboxPipeline;
public class BlackboxPipelineTest {
@Test
public void resetTest() {
List<String> data = Arrays.asList("Pacer", "Pipes", "Test");
Pipe<String, String> pipe1 = new IdentityPipe<String>();
Pipe<String, String> pipe2 = new IdentityPipe<String>();
BlackboxPipeline<String, String> blackboxPipeline = new BlackboxPipeline<String, String>(pipe1, pipe2);
blackboxPipeline.setStarts(data);
pipe2.setStarts(data);
int count = 0;
while (blackboxPipeline.hasNext()) {
assertEquals(blackboxPipeline.next(), data.get(count));
blackboxPipeline.reset();
count++;
}
assertEquals(count, data.size());
assertFalse(blackboxPipeline.hasNext());
}
}
Version data entries
11 entries across 11 versions & 1 rubygems