@Test public void batchReturnsMoreThanInput() {

  Funnel.Batch<Integer, String> toSpell = funnel.through(batch::send);
  toSpell.accept(1);
  when(batch.send(asList(1))).thenReturn(asList("one", "two"));
  assertThrows(IllegalStateException.class, funnel::run);
}