smitsgit

package iter

import java.io.File
import kotlin.coroutines.experimental.buildSequence

fun main(args: Array<String>) {
    val file = File("path-to/access-log")
    val linesInFile = getLines(file)
    val bytesColumn = getBytesColumn(linesInFile)
    val bytes = getBytes(bytesColumn)

smitsgit

import java.io.IOException;
import java.util.List;

import rx.Observable;
import rx.Subscriber;
import rx.Subscription;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Func0;
import rx.functions.Func1;