Add LogReaderSingleSequence

Author: pambrose

build.gradle.kts

@@ -1,3 +1,5 @@
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
+
 plugins {
     kotlin("jvm") version "1.3.21"
 }
@@ -6,7 +8,7 @@ group = "org.athenian"
 version = "1.0-SNAPSHOT"
 
 repositories {
-    mavenCentral(),
+    mavenCentral()
     mavenLocal()
 }
 
@@ -16,4 +18,4 @@ dependencies {
 
 tasks.withType<KotlinCompile> {
     kotlinOptions.jvmTarget = "1.8"
-}
+}

src/main/kotlin/org/athenian/LazyLogReader.kt renamed to src/main/kotlin/org/athenian/LogReaderMultipleSequences.kt

@@ -26,7 +26,7 @@ fun getBytesColumn(data: Sequence<String>) =
     sequence {
         for (line in data) {
             val cols = line.split(" ")
-            if (cols.isEmpty() || cols.size != 19)
+            if (cols.size != 19)
                 continue
             val bytes = cols[9]
             yield(bytes)

src/main/kotlin/org/athenian/LogReaderSingleSequence.kt

@@ -0,0 +1,24 @@
+package org.athenian
+
+import java.io.File
+
+fun main() {
+    val file = File("data/access.log")
+    val lines =
+        sequence {
+            val data = file.bufferedReader().lineSequence()
+            for (line in data) {
+                yield(line)
+            }
+        }
+    val bytes =
+        lines
+            .map { it.split(" ") }
+            .filter { it.size == 19 }
+            .map { it[9] }
+            .filter { it != "-" }
+            .map { it.toInt() }
+    val total = bytes.sum()
+    println("Total bytes: $total")
+}
+