SpoutWrapper extends RichParallelSourceFunction<OUT> implements StoppableFunction { @Override public void close() throws Exception { this.spout.close(); } SpoutWrapper(final IRichSpout spout);  SpoutWrapper(final IRichSpout spout, final Integer numberOfInvocations);  SpoutWrapper(final IRichSpout spout, final String[] rawOutputs);  SpoutWrapper(final IRichSpout spout, final String[] rawOutputs,
			final Integer numberOfInvocations);  SpoutWrapper(final IRichSpout spout, final Collection<String> rawOutputs);  SpoutWrapper(final IRichSpout spout, final Collection<String> rawOutputs,
			final Integer numberOfInvocations);  SpoutWrapper(final IRichSpout spout, final String name, final Collection<String> rawOutputs,
			final Integer numberOfInvocations); void setStormTopology(StormTopology stormTopology); @Override final void run(final SourceContext<OUT> ctx); @Override void cancel(); @Override void stop(); @Override void close();  }
@Test public void testClose() throws Exception { final IRichSpout spout = mock(IRichSpout.class); final SpoutWrapper<Tuple1<Integer>> spoutWrapper = new SpoutWrapper<Tuple1<Integer>>(spout); spoutWrapper.close(); verify(spout).close(); }