Searched refs:elementFunnel (Results 1 – 2 of 2) sorted by relevance
161 public static <E> Funnel<Iterable<? extends E>> sequentialFunnel(Funnel<E> elementFunnel) { in sequentialFunnel() argument162 return new SequentialFunnel<E>(elementFunnel); in sequentialFunnel()166 private final Funnel<E> elementFunnel; field in Funnels.SequentialFunnel168 SequentialFunnel(Funnel<E> elementFunnel) { in SequentialFunnel() argument169 this.elementFunnel = Preconditions.checkNotNull(elementFunnel); in SequentialFunnel()174 elementFunnel.funnel(e, into); in funnel()179 return "Funnels.sequentialFunnel(" + elementFunnel + ")"; in toString()185 return elementFunnel.equals(funnel.elementFunnel); in equals()191 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()