org.apache.streams.local.test.processors (streams-runtime-local 0.5-incubating Test API)