@Test public void testCancelled() throws Exception { doNothing().when(helper).add(any(Byte.class), anyObject()); doNothing().when(helper).checkFailed(); helper.cancelled(); verify(helper).add(CollectHelper.CANCELLED, null); verify(helper).checkFailed(); }
@Override public void cancelled() { add(CANCELLED, null); checkFailed(); }
CollectHelper implements Handle<T> { @Override public void cancelled() { add(CANCELLED, null); checkFailed(); } }
CollectHelper implements Handle<T> { @Override public void cancelled() { add(CANCELLED, null); checkFailed(); } CollectHelper(
      int size, Function<? super Collection<T>, ? extends U> collector,
      Collection<? extends Stage<?>> sources, Completable<? super U> target
  ); }
CollectHelper implements Handle<T> { @Override public void cancelled() { add(CANCELLED, null); checkFailed(); } CollectHelper(
      int size, Function<? super Collection<T>, ? extends U> collector,
      Collection<? extends Stage<?>> sources, Completable<? super U> target
  ); @Override void completed(T result); @Override void failed(Throwable e); @Override void cancelled(); }
CollectHelper implements Handle<T> { @Override public void cancelled() { add(CANCELLED, null); checkFailed(); } CollectHelper(
      int size, Function<? super Collection<T>, ? extends U> collector,
      Collection<? extends Stage<?>> sources, Completable<? super U> target
  ); @Override void completed(T result); @Override void failed(Throwable e); @Override void cancelled();  }