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