transform<R> method

LxStream<R> transform<R>(Stream<R> transformer(Stream<T> stream))

Transforms the stream of changes using transformer.

Returns a new LxStream reflecting the transformed data.

Implementation

LxStream<R> transform<R>(Stream<R> Function(Stream<T> stream) transformer) {
  return LxStream<R>(transformer(stream));
}