jwkidd3 · January 18, 2017 22:16
diff --git a/windows bytime b/windows bytime
 Observable.interval(100, TimeUnit.MILLISECONDS)
    .take(5)
    .window(250, 100, TimeUnit.MILLISECONDS)
    .flatMap(o -> o.toList())
    .subscribe(System.out::println);
	Observable.interval(100, TimeUnit.MILLISECONDS)
	.take(5)
	.window(250, 100, TimeUnit.MILLISECONDS)
	.flatMap(o -> o.toList())
	.subscribe(System.out::println);