com.shakelang.util.common-io/com.shakelang.util.io.streaming

Package-level declarations

Types

AppendableStream

class AppendableStream<T> : Stream<T>

A LinkedList-based stream that can be appended to

ArrayStream

class ArrayStream<T>(array: Array<T>) : Stream<T>

Create a stream from an array

FlatStream

class FlatStream<T>(stream: Stream<out Stream<T>>) : Stream<T>

A stream that flattens a stream of streams

IndexedMapStream

class IndexedMapStream<T, R>(stream: Stream<T>, mapper: (Int, T) -> R) : Stream<R>

IteratorStream

class IteratorStream<T>(iterator: Iterator<T>) : Stream<T>

Create a stream from an iterator

ListStream

class ListStream<T>(list: List<T>) : Stream<T>

Create a stream from a list The stream internally uses the list's iterator (because, depending on the list's implementation, there might be performance gains over using the list's get method)

MapStream

class MapStream<T, R>(stream: Stream<T>, mapper: (T) -> R) : Stream<R>

Map a stream to another stream

SequenceStream

class SequenceStream<T>(sequence: Sequence<T>) : Stream<T>

Create a stream from a sequence

Stream

interface Stream<T>

A stream is a sequence of elements that can be read one by one

Functions

flatten

fun <T> Stream<out Stream<T>>.flatten(): FlatStream<T>

stream

fun <T> Array<T>.stream(): ArrayStream<T>

Create a Stream from an Array

fun <T> Iterator<T>.stream(): IteratorStream<T>

Create a Stream from an Iterator

fun <T> List<T>.stream(): ListStream<T>

Create a Stream from a List

fun <T> Sequence<T>.stream(): SequenceStream<T>

Create a Stream from a Sequence

streamOf

fun <T> streamOf(vararg elements: T): IteratorStream<T>

Create a Stream from a Sequence