Searched refs:elementFunnel (Results 1 – 2 of 2) sorted by relevance
172 public static <E> Funnel<Iterable<? extends E>> sequentialFunnel(Funnel<E> elementFunnel) { in sequentialFunnel() argument173 return new SequentialFunnel<E>(elementFunnel); in sequentialFunnel()177 private final Funnel<E> elementFunnel; field in Funnels.SequentialFunnel179 SequentialFunnel(Funnel<E> elementFunnel) { in SequentialFunnel() argument180 this.elementFunnel = Preconditions.checkNotNull(elementFunnel); in SequentialFunnel()185 elementFunnel.funnel(e, into); in funnel()190 return "Funnels.sequentialFunnel(" + elementFunnel + ")"; in toString()196 return elementFunnel.equals(funnel.elementFunnel); in equals()202 return SequentialFunnel.class.hashCode() ^ elementFunnel.hashCode(); in hashCode()
101 Funnel<Object> elementFunnel = mock(Funnel.class); in testSequential() local103 Funnel<Iterable<? extends Object>> sequential = Funnels.sequentialFunnel(elementFunnel); in testSequential()105 InOrder inOrder = inOrder(elementFunnel); in testSequential()106 inOrder.verify(elementFunnel).funnel("foo", primitiveSink); in testSequential()107 inOrder.verify(elementFunnel).funnel("bar", primitiveSink); in testSequential()108 inOrder.verify(elementFunnel).funnel("baz", primitiveSink); in testSequential()109 inOrder.verify(elementFunnel).funnel("quux", primitiveSink); in testSequential()