FusedPartitionedInvocationCtx implements InternalInvocationCtx, OutputCollector { @Override public int getInputCount () { return inputCount; } FusedPartitionedInvocationCtx( final int inputPortCount,
                                           final Function<PartitionKey, KVStore> kvStoreSupplier,
                                           final PartitionKeyExtractor partitionKeyExtractor,
                                           final OutputCollector outputCollector ); @Override void setInvocationReason( final InvocationReason reason ); @Override void reset(); @Override int getInputCount(); @Override boolean nextInput(); @Override void setUpstreamConnectionStatuses( final boolean[] upstreamConnectionStatuses ); @Override List<TuplesImpl> getInputs(); @Override OutputCollector getOutputCollector(); @Override List<Tuple> getInputTuples( final int portIndex ); @Override Tuple getInputTupleOrNull( final int portIndex, final int tupleIndex ); @Override int getInputTupleCount( final int portIndex ); @Override void output( final Tuple tuple ); @Override void output( final List<Tuple> tuples ); @Override void output( final int portIndex, final Tuple tuple ); @Override void output( final int portIndex, final List<Tuple> tuples ); @Override InvocationReason getReason(); @Override boolean isInputPortOpen( final int portIndex ); @Override PartitionKey getPartitionKey(); @Override KVStore getKVStore(); TuplesImpl getInput(); @Override void add( final Tuple tuple ); @Override void add( final int portIndex, final Tuple tuple ); @Override void recordInvocationLatency( final String operatorId, final long latency ); @Override TuplesImpl getOutputTuples(); @Override void clear();  }
@Test public void when_noOutputIsAdded_then_noInputIsPresent () { assertThat( invocationCtx.getInputCount(), equalTo( 0 ) ); }