Stream

Build Stream Interface

Build methods extend stream pipeline creating functionality which will add, remove or modify stream elements, when they finally start moving throught the pipeline.

Once a single stream build method is invoked, the original stream object must not be used, all further processing must be done with the newly created stream.

Build Stream Interface

Build methods extend stream pipeline creating functionality which will add, remove or modify stream elements, when they finally start moving throught the pipeline.

Once a single stream build method is invoked, the original stream object must not be used, all further processing must be done with the newly created stream.

Stream Consumption Interface

Once a single stream consumption method is invoked, the stream object should generally be discarded. The only exceptions are methods defined in _metadata and _read interfaces.

Stream Consumption Interface

Once a single stream consumption method is invoked, the stream object should generally be discarded. The only exceptions are methods defined in _metadata and _read interfaces.

Object Custom holds advanced stream features, average users should not be concerned about.

Stream Flow

Flow is similar to stream, but without sequence specific methods.

Elements of Flow can be processed either in parallel or sequentially.

Flow is usually created from stream with ".parallel" method.

  val flow: Stream.Flow[Int] = (1 <> 10).stream.parallel

Stream Flow

Flow is similar to stream, but without sequence specific methods.

Elements of Flow can be processed either in parallel or sequentially.

Flow is usually created from stream with ".parallel" method.

  val flow: Stream.Flow[Int] = (1 <> 10).stream.parallel

Preview is an extension of stream with preview capabilities

It allows to pre-load and inspect elements before they are read from the stream

val s  : Stream[Int]         = 1 <> 10
val ps : Stream.Preview[Int] = s.enablePreview

ps.preview.tp            // Prints  1

ps.previewStream(5).tp       // Prints  Stream(1, 2, 3, 4, 5)

ps.previewStream(3).tp       // Prints  Stream(1, 2, 3)

(ps.previewSize > 12).tp // Prints false

ps.tp                    // Prints Stream(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
ps.tp                    // Prints Stream()

Preview is an extension of stream with preview capabilities

It allows to pre-load and inspect elements before they are read from the stream

val s  : Stream[Int]         = 1 <> 10
val ps : Stream.Preview[Int] = s.enablePreview

ps.preview.tp            // Prints  1

ps.previewStream(5).tp       // Prints  Stream(1, 2, 3, 4, 5)

ps.previewStream(3).tp       // Prints  Stream(1, 2, 3)

(ps.previewSize > 12).tp // Prints false

ps.tp                    // Prints Stream(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
ps.tp                    // Prints Stream()