<commit_before>define([
    './stream/stream',
    './stream/map',
    './stream/filter',
    './stream/take',
    './stream/distinct',
    './stream/debounce',
    './stream/when',
    './stream/noop',
    './stream/fromArray',
    './stream/fromPromise'
], function(
    Stream,
    map,
    filter,
    take,
    distinct,
    debounce,
    when,
    noop,
    fromArray,
    fromPromise
) {
    'use strict';

    Stream.prototype.map = function(fn) {
        return map(fn, this);
    };
    Stream.prototype.filter = function(fn) {
        return filter(fn, this);
    };
    Stream.prototype.take = function(n) {
        return take(n, this);
    };
    Stream.prototype.distinct = function() {
        return distinct(this);
    };
    Stream.prototype.debounce = function(timeout) {
        return debounce(timeout, this);
    };

    Stream.fromArray = fromArray;
    Stream.fromPromise = fromPromise;
    Stream.when = when;
    Stream.noop = noop;

    return Stream;
});
<commit_msg>Export missing streams like "both" and "fromEvent"<commit_after>define([
    './stream/stream',
    './stream/map',
    './stream/filter',
    './stream/take',
    './stream/both',
    './stream/distinct',
    './stream/debounce',
    './stream/when',
    './stream/noop',
    './stream/fromArray',
    './stream/fromEvent',
    './stream/fromPromise'
], function(
    Stream,
    map,
    filter,
    take,
    both,
    distinct,
    debounce,
    when,
    noop,
    fromArray,
    fromEvent,
    fromPromise
) {
    'use strict';

    Stream.prototype.map = function(fn) {
        return map(fn, this);
    };
    Stream.prototype.filter = function(fn) {
        return filter(fn, this);
    };
    Stream.prototype.take = function(n) {
        return take(n, this);
    };
    Stream.prototype.distinct = function() {
        return distinct(this);
    };
    Stream.prototype.debounce = function(timeout) {
        return debounce(timeout, this);
    };

    Stream.fromArray = fromArray;
    Stream.fromEvent = fromEvent;
    Stream.fromPromise = fromPromise;
    Stream.both = both;
    Stream.when = when;
    Stream.noop = noop;

    return Stream;
});

{'fraction_non_alphanumeric': 0.1556276053728578, 'fraction_numerical': 0.0, 'mean_word_length': 2.209509658246657, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7269944', 'n_tokens_mistral': 686, 'n_tokens_neox': 693, 'n_words': 130}