### Question:
CustomSubscriber extends AbstractSubscriber<T> { @Override protected void acceptEvent(T event) throws Exception { receiver.accept(event); } CustomSubscriber(@NonNull Class<T> eventClass, @NonNull Consumer<T> receiver); @SuppressWarnings("WeakerAccess") CustomSubscriber<T> withFilter(@NonNull Predicate<T> filter); @SuppressWarnings("WeakerAccess") CustomSubscriber<T> withScheduler(@NonNull Scheduler scheduler); @Override boolean equals(Object other); @Override int hashCode();  }### Answer:
@Test public void testAcceptEvent() throws Exception { subscriber.acceptEvent(object); verify(receiver).accept(object); }