erickoknl
fun <T> Flowable<Array<T>>.flatten(): Flowable<T> { return this.flatMapIterable { items -> Arrays.asList(*items) } }