스트림의 마지막 x 요소 건너 뛰기 <T>

Question

Stream<T>이 있으면 skip(long)을 사용하여 스트림의 처음 몇 요소를 건너 뛸 수 있습니다. 그러나 스트림의 끝에서 지정된 수의 요소를 건너 뛰는 것과 동일한 요소가없는 것으로 보입니다.

가장 확실한 해결책은 limit(originalLength - elementsToRemoveAtEnd)을 사용하는 것입니다.하지만 그 전에는 항상 초기 길이를 알아야합니다. 이는 항상 그런 것은 아닙니다.

알 수없는 길이의 스트림의 마지막 몇 요소를 Collection에 수집하지 않고 제거하고 요소를 계산하여 다시 스트림하는 방법이 있습니까?

Answer 1

길이가 알려지지 않은 Stream에 대한 일반적인 저장 장치없는 해결 방법은 없습니다.

이

static <T> Stream<T> skipLastElements(Stream<T> s, int count) { 
    if(count<=0) { 
     if(count==0) return s; 
     throw new IllegalArgumentException(count+" < 0"); 
    } 
    ArrayDeque<T> pending=new ArrayDeque<T>(count+1); 
    Spliterator<T> src=s.spliterator(); 
    return StreamSupport.stream(new Spliterator<T>() { 
     public boolean tryAdvance(Consumer<? super T> action) { 
      while(pending.size()<=count && src.tryAdvance(pending::add)); 
      if(pending.size()>count) { 
       action.accept(pending.remove()); 
       return true; 
      } 
      return false; 
     } 
     public Spliterator<T> trySplit() { 
      return null; 
     } 
     public long estimateSize() { 
      return src.estimateSize()-count; 
     } 
     public int characteristics() { 
      return src.characteristics(); 
     } 
    }, false); 
} 
public static void main(String[] args) { 
    skipLastElements(Stream.of("foo", "bar", "baz", "hello", "world"), 2) 
    .forEach(System.out::println); 
} 

Answer 2

다음 코드는 n가 어디 n 요소를 버퍼 ArrayDeque를 사용하지만, 전체 스트림을 수집 할 필요가 없습니다 요소의 수는 건너 뛰려면, 당신은 단지 대규모로 저장이 필요 끝에 건너 뛸 요소 수. 트릭은 skip(n)을 사용하는 것입니다. 이로 인해 첫 번째 n 요소가 ArrayDeque에 추가됩니다. 그런 다음, n 요소가 버퍼링되면 스트림은 요소 처리를 계속하지만 ArrayDeque의 요소를 팝합니다. 스트림의 끝 부분에 도달하면 n 요소가 ArrayDeque에 붙어 버려지고 버려집니다.

ArrayDeque은 null 요소를 허용하지 않습니다. 아래 코드는 ArrayDeque에 추가하기 전에 null을 NULL_VALUE에 매핑 한 다음 ArrayDeque에서 터지게 한 후 NULL_VALUE을 null으로 다시 매핑합니다.

private static final Object NULL_VALUE = new Object(); 

public static <T> Stream<T> skipLast(Stream<T> input, int n)     
{ 
    ArrayDeque<T> queue; 

    if (n <= 0) 
     return(input); 

    queue = new ArrayDeque<>(n + 1); 

    input = input. 
     map(item -> item != null ? item : NULL_VALUE). 
     peek(queue::add). 
     skip(n). 
     map(item -> queue.pop()). 
     map(item -> item != NULL_VALUE ? item : null); 

    return(input); 
}