expand<R> method

LxStream<R> expand<R>(
  1. Iterable<R> convert(
    1. T element
    )
)

Expands each event into an iterable of events.

Implementation

LxStream<R> expand<R>(Iterable<R> Function(T element) convert) {
  return LxStream<R>.defer(() => valueStream.expand(convert));
}