package com.github.davidmoten.rx.util;

import org.junit.Test;

public class DrainerSyncBiasedTest {

    @Test
    public void test() {
        
    }
}

@@ -44,106 +44,1412 @@
 ort 
-org.junit.Test;%0A%0Apublic class DrainerSyncBiasedTest %7B%0A%0A    @Test%0A    public void test() %7B%0A        
+static org.junit.Assert.assertEquals;%0A%0Aimport java.util.concurrent.atomic.AtomicInteger;%0A%0Aimport org.junit.Test;%0A%0Aimport rx.Observable;%0Aimport rx.Observable.OnSubscribe;%0Aimport rx.Subscriber;%0A%0Aimport com.github.davidmoten.rx.Transformers;%0A%0Apublic class DrainerSyncBiasedTest %7B%0A%0A    @Test%0A    public void test() %7B%0A        final AtomicInteger count = new AtomicInteger(0);%0A        Observable.create(new OnSubscribe%3CInteger%3E() %7B%0A%0A            @Override%0A            public void call(Subscriber%3C? super Integer%3E subscriber) %7B%0A                for (int i = 0; i %3C 1000; i++)%0A                    subscriber.onNext(i);%0A                subscriber.onCompleted();%0A            %7D%0A%0A        %7D)%0A        // buffer%0A                .compose(Transformers.%3CInteger%3E bufferEmissions())%0A                // subscribe%0A                .subscribe(new Subscriber%3CInteger%3E() %7B%0A%0A                    @Override%0A                    public void onStart() %7B%0A                        request(200);%0A                    %7D%0A%0A                    @Override%0A                    public void onCompleted() %7B%0A%0A                    %7D%0A%0A                    @Override%0A                    public void onError(Throwable e) %7B%0A                    %7D%0A%0A                    @Override%0A                    public void onNext(Integer t) %7B%0A                        count.incrementAndGet();%0A                    %7D%0A                %7D);%0A        assertEquals(200, count.get());
 %0A   

add test for DrainerSyncBiased