Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
navis committed Dec 24, 2019
1 parent 0d4f2cc commit fc51fad
Show file tree
Hide file tree
Showing 7 changed files with 173 additions and 342 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
package io.druid.java.util.common.guava;

import com.google.common.base.Function;
import com.google.common.base.Preconditions;
import com.google.common.base.Predicate;
import com.google.common.collect.Lists;

Expand Down Expand Up @@ -44,6 +43,7 @@ public static <T> Sequence<T> empty()
return (Sequence<T>) EMPTY_SEQUENCE;
}

@SafeVarargs
public static <T> Sequence<T> concat(Sequence<T>... sequences)
{
return concat(Arrays.asList(sequences));
Expand Down Expand Up @@ -79,17 +79,6 @@ public static <T> Sequence<T> withBaggage(final Sequence<T> seq, Closeable bagga
return new ResourceClosingSequence<>(seq, baggage);
}

/**
* Allows to execute something before, after or around the processing of the given sequence. See documentation to
* {@link SequenceWrapper} methods for some details.
*/
public static <T> Sequence<T> wrap(Sequence<T> seq, SequenceWrapper wrapper)
{
Preconditions.checkNotNull(seq, "seq");
Preconditions.checkNotNull(wrapper, "wrapper");
return new WrappingSequence<>(seq, wrapper);
}

public static <T> Sequence<T> withEffect(final Sequence <T> seq, final Runnable effect, final Executor exec)
{
return new Sequence<T>()
Expand Down

This file was deleted.

This file was deleted.

Loading

0 comments on commit fc51fad

Please sign in to comment.