DefaultOutputPort implements Operator.OutputPort<T> { public void emit(T tuple) { verifyOperatorThread(); sink.put(tuple); } DefaultOutputPort(); void emit(T tuple); @Override void setSink(Sink<Object> s); boolean isConnected(); @Override Unifier<T> getUnifier(); @Override void setup(PortContext context); @Override void teardown(); static final String THREAD_AFFINITY_DISABLE_CHECK; }
@Test public void testSetupNotCalledAndEmit() { port.emit(null); Assert.assertEquals(1, sink.getCount(false)); }