streamex

1熱度

1回答

請考慮以下示例代碼。此代碼使用Eclipse的@NonNull和@Nullable註釋來檢查null s。不幸的是，Eclipse在行map(toNonNull)上標記了一個錯誤。 import java.util.function.Function; import org.eclipse.jdt.annotation.NonNull; import org.eclipse.jdt.annot

1熱度

4回答

StreamEx分組到列表返回不正確的記錄數

以下代碼將對象流拆分爲1000塊，在實例化過程中處理它們，並返回最後的對象總數。在號碼返回的所有情況下是正確的，除非該流的大小恰好是1.在流大小爲1的情況下，返回的數是0。任何幫助，將不勝感激。在流中沒有記錄爲0的情況下，我也必須破解返回調用。我想解決這個問題。 AtomicInteger recordCounter = new AtomicInteger(0); try (StreamEx

3熱度

1回答

如何解開StreamEx到「普通舊Java流」？

StreamEx是一個強大的庫，但在某些時候，我不再需要它的超級大國了。我該如何擺脫StreamEx內部開銷？這可能會造成問題嗎？ Ex。 public void process(Path path){ StreamEx.of(Files.lines(path)) .groupRuns(...) //See below .unwrap()

3熱度

1回答

使用takeWhile時StreamEx並行性應該如何工作？

我有我創建這樣一個流： StreamEx.generate(new MySupplier<List<Entity>>()) .flatMap(List::stream) .map(Entity::getName) .map(name -> ...) .. // more stuff 我可以改變這個只需添加parallel並行工作： StreamE

-1熱度

1回答

創建SimpleEntry和StreamEx

一個地圖，我看到StreamEx至極的例子是相當不錯的，並且是這樣的 Map<String, String> toMap = StreamEx.of(splittedTimeUnit1) .pairMap((s1, s2) -> s1.matches("-?\\d+(\\.\\d+)?") ? new String[]{s2, s1} : null) .nonNull(

0熱度

1回答

一個方法添加到Java 8個流

雖然與Java 8 Stream s工作，我有時發現Stream沒有我的願望（例如takeWhile()，dropWhile()，skipLast()）的具體方法。我如何創建自己的流類，它具有額外的方法，無需重寫整個Java 8架構？我知道StreamEx庫，知道它有takeWhile()和dropWhile()。在撰寫本文時，它沒有skipLast()。我已經爲此方法提交了an issue。