adding most is the terminal operations - partitioning, joining, and iterator ops are missing yet

streamjs/streamjs.d.ts

@@ -10,15 +10,40 @@ declare class Stream<T> {
 	static rangeClosed (startInclusive: number, endInclusive: number): Stream<number>;
 	static generate <T> (supplier: () => T): Stream<T>;
 	
+	anyMatch(predicate: (elem: T) => boolean): boolean;
+	anyMatch(regexp: RegExp): boolean;
+	allMatch(predicate: (elem: T) => boolean): boolean;
+	allMatch(regexp: RegExp): boolean;
+	average(): number;
+	avg(): number;
+	collect(collector: Stream.Collector<T>): T;
+	count(): number;
 	distinct(): Stream<T>;
 	dropWhile(predicate: (elem: T) => boolean): Stream<T>;
 	dropWhile(regexp: RegExp): Stream<string>;
 	filter(predicate: (T) => boolean): Stream<T>;
+	findAny(): Stream.Optional<T>;
+	findFirst(): Stream.Optional<T>;
+	forEach(consumer: (elem: T) => void): void;
+	
+	groupBy(mapper: (elem: T) => string): Stream.GroupingResult<T>;
+	groupingBy(mapper: (elem: T) => string): Stream.GroupingResult<T>;
+	toMap(keyMapper: (elem: T) => string, mergeFunction?: (elem1: T, elem2: T) => T): T[];
+	
 	map <U> (mapper: (T) => U): Stream<U>;
+	max(): Stream.Optional<T>;
+	max(comparator: (e1: T, e2: T) => number): Stream.Optional<T>;
+	min(): Stream.Optional<T>;
+	min(comparator: (elem1: T, elem2: T) => number): Stream.Optional<T>;
+	noneMatch(predicate: (elem: T) => boolean): boolean;
+	noneMatch(regexp: RegExp): boolean;
 	flatMap <U> (mapper: (T) => U[]): Stream<U>;
 	limit(limit: number): Stream<T>;
 	peek(consumer: (elem: T) => void ): Stream<T>;
+	reduce(identity: T, accumulator: (e1: T, e2: T) => T): T;
+	reduce(accumulator: (e1: T, e2: T) => T): Stream.Optional<T>;
 	reverse(): Stream<T>;
+	size(): number;
 	sorted(): Stream<T>;
 	sorted(comparator: (e1: T, e2: T) => number): Stream<T>;
 	sort(): Stream<T>;
@@ -26,7 +51,24 @@ declare class Stream<T> {
 	shuffle(): Stream<T>;
 	skip(n: number): Stream<T>;
 	slice(begin, end): Stream<T>;
+	sum(): T;
 	takeWhile(predicate: (elem: T) => boolean): Stream<T>;
 	takeWhile(regexp: RegExp): Stream<string>;
 	toArray(): T[];
 }
+
+declare module Stream {
+	export interface GroupingResult<T> {
+		[index: string]: T
+	}
+
+	export interface Collector<T> {
+		supplier(): T;
+		accumulator(e1: T, e2: T): T;
+		finisher(result: T): T
+	}
+
+	export class Optional<T> {
+
+	}
+}