<commit_before>package com.github.davidmoten.bigsort;

import java.util.ArrayList;
import java.util.List;

import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Producer;
import rx.Subscriber;
import rx.functions.Func1;

public class OperatorRefreshSelect<T> implements OnSubscribe<T> {

	private final Iterable<Observable<T>> sources;
	private final Func1<? extends List<? extends T>, T> selector;

	public OperatorRefreshSelect(Iterable<Observable<T>> sources,
			Func1<? extends List<? extends T>, T> selector) {
		this.sources = sources;
		this.selector = selector;
	}

	@Override
	public void call(final Subscriber<? super T> child) {
		child.setProducer(new MyProducer<T>(sources, selector));
	}

	private static class MyProducer<T> implements Producer {

		private final Iterable<Observable<T>> sources;
		private final List<Subscriber<T>> subscribers;
		private final Func1<? extends List<? extends T>, T> selector;

		public MyProducer(Iterable<Observable<T>> sources,
				Func1<? extends List<? extends T>, T> selector) {
			this.sources = sources;
			this.selector = selector;
			this.subscribers = new ArrayList<Subscriber<T>>();
			for (Observable<T> source : sources) {
				subscribers.add(new SourceSubscriber<T>(source));
			}
		}

		@Override
		public void request(long n) {

		}

	}

	private static class SourceSubscriber<T> extends Subscriber<T> {

		public SourceSubscriber(Observable<T> source) {
		}

		@Override
		public void onCompleted() {
			// TODO Auto-generated method stub

		}

		@Override
		public void onError(Throwable e) {
			// TODO Auto-generated method stub

		}

		@Override
		public void onNext(T t) {
			// TODO Auto-generated method stub

		}

	}

}<commit_msg>OperatorRefreshSelect dev<commit_after>package com.github.davidmoten.bigsort;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;

import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Producer;
import rx.Subscriber;
import rx.functions.Func1;

public class OperatorRefreshSelect<T> implements OnSubscribe<T> {

	private final Iterable<Observable<T>> sources;
	private final Func1<? extends Set<? extends T>, T> selector;

	public OperatorRefreshSelect(Iterable<Observable<T>> sources,
			Func1<? extends Set<? extends T>, T> selector) {
		this.sources = sources;
		this.selector = selector;
	}

	@Override
	public void call(final Subscriber<? super T> child) {
		child.setProducer(new MyProducer<T>(sources, selector));
	}

	private static class MyProducer<T> implements Producer {

		private final Iterable<Observable<T>> sources;
		private final List<SourceSubscriber<T>> subscribers;
		private final Func1<? extends Set<? extends T>, T> selector;

		public MyProducer(Iterable<Observable<T>> sources,
				Func1<? extends Set<? extends T>, T> selector) {
			this.sources = sources;
			this.selector = selector;
			this.subscribers = new ArrayList<SourceSubscriber<T>>();
			for (Observable<T> source : sources) {
				subscribers.add(new SourceSubscriber<T>(source));
			}
			for (SourceSubscriber<T> ss : subscribers) {
				ss.requestMore(1);
			}
		}

		@Override
		public void request(long n) {

		}

	}

	private static class SourceSubscriber<T> extends Subscriber<T> {

		public SourceSubscriber(Observable<T> source) {
		}

		void requestMore(long n) {
			request(n);
		}

		@Override
		public void onCompleted() {
			// TODO Auto-generated method stub

		}

		@Override
		public void onError(Throwable e) {
			// TODO Auto-generated method stub

		}

		@Override
		public void onNext(T t) {
			// TODO Auto-generated method stub

		}

	}

}
{'fraction_non_alphanumeric': 0.1125312586829675, 'fraction_numerical': 0.0030564045568213394, 'mean_word_length': 4.317577548005908, 'pattern_counts': {'":': 0, '<': 64, '<?xml version=': 0, '>': 64, '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': '6817578', 'n_tokens_mistral': 1266, 'n_tokens_neox': 1110, 'n_words': 302}