yadunut/nus
1
0
Fork 0
Code Issues Pull Requests Actions Projects Releases Wiki Activity

feat: solve 9b

Browse Source
This commit is contained in:
Yadunand Prem 2022-11-12 13:07:08 +08:00
parent 538b71a980
commit 13f372ec5a
1 changed files with 30 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
cs2030s/Lab9/Lab9b/Streaming.java
View File

@ -4,7 +4,34 @@ import java.util.List;
import java.util.ArrayList;
public class Streaming {
public static <T> List<Pair<Integer, T>> encode(Stream<T> stream) {
return null; // Modify this
}
public static <T> List<Pair<Integer, T>> encode(Stream<T> stream) {
return stream
.<List<Pair<Integer, T>>>collect(
ArrayList::new,
(acc, t) -> {
if (acc.isEmpty()) {
acc.add(new Pair<Integer, T>(1, t));
return;
}
Pair<Integer, T> last = acc.get(acc.size() - 1);
if (last.getSnd().equals(t)) {
last.setFst(last.getFst() + 1);
} else {
acc.add(new Pair<>(1, t));
}
},
(pair1, pair2) -> {
if (pair1.isEmpty()) {
pair1.addAll(pair2);
return;
}
Pair<Integer, T> last = pair1.get(pair1.size() - 1);
Pair<Integer, T> first = pair2.get(0);
if (last.getSnd().equals(first.getSnd())) {
last.setFst(last.getFst() + first.getFst());
pair2.remove(0);
}
pair1.addAll(pair2);
});
}
}