<commit_before>package <%= appPackage %>.base.util

import io.reactivex.disposables.CompositeDisposable
import io.reactivex.disposables.Disposable

operator fun CompositeDisposable.plusAssign(disposable: Disposable) {
  this.add(disposable)
}
fun <T> Observable<T>.intervalEmitted(time: Long = 1,
                                      timeUnit: TimeUnit = TimeUnit.SECONDS): Observable<T> {
  return this.zipWith(Observable.interval(time, timeUnit), BiFunction { value, _ -> value })
}<commit_msg>fixed not having all the imports in rxutil<commit_after>package <%= appPackage %>.base.util

import io.reactivex.Observable
import io.reactivex.disposables.CompositeDisposable
import io.reactivex.disposables.Disposable
import io.reactivex.functions.BiFunction
import java.util.concurrent.TimeUnit

operator fun CompositeDisposable.plusAssign(disposable: Disposable) {
  this.add(disposable)
}
fun <T> Observable<T>.intervalEmitted(time: Long = 1,
                                      timeUnit: TimeUnit = TimeUnit.SECONDS): Observable<T> {
  return this.zipWith(Observable.interval(time, timeUnit), BiFunction { value, _ -> value })
}
{'fraction_non_alphanumeric': 0.10600706713780919, 'fraction_numerical': 0.0017667844522968198, 'mean_word_length': 4.294392523364486, 'pattern_counts': {'":': 0, '<': 11, '<?xml version=': 0, '>': 13, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 2, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3116117', 'n_tokens_mistral': 355, 'n_tokens_neox': 327, 'n_words': 67}