ballerina/lang.stream Ballerina library

Applies a function to each member of a stream and returns a stream of the results.

stream<float> ms = [14.5f, 45.5f, 6.8f, 4f].toStream();
stream<float> cms = ms.map(m => m * 100.0);
cms.next() ⇒ {"value":1450.0}

Closes a stream.

This releases any system resources being used by the stream. Closing a stream that has already been closed has no effect and returns ().

stream<int, error?> strm = new;
check strm.close();

Selects the members from a stream for which a function returns true.

stream<int> scores = [45, 60, 75, 30, 90].toStream();
scores.filter(score => score > 50).next() ⇒ {"value":60}

Applies a function to each member of a stream.

The parameter func is applied to each member of parameter stm stream in order.

stream<int> scores = [45, 60, 75, 30, 90].toStream();
int total = 0;
scores.forEach(function(int score) {
    total += score;
});
total ⇒ 300

Returns an iterator over a stream.

stream<int> scores = [45, 60, 75, 30, 90].toStream();
object {
    public isolated function next() returns record {|int value;|}?;
} iterator = scores.iterator();
iterator.next() ⇒ {"value":45}

Returns the next element in the stream wrapped in a record or () if the stream ends.

stream<int> scores = [45, 60, 75, 30, 90].toStream();
scores.next() ⇒ {"value":45}

Combines the members of a stream using a combining function.

The combining function takes the combined value so far and a member of the stream, and returns a new combined value.

stream<int> scores = [45, 60, 75, 30, 90].toStream();
scores.reduce(isolated function (int total, int score) returns int => total + score, 0) ⇒ 300