@@ -0,0 +1,995 @@
+package com.github.davidmoten.rx.operators;%0A%0Aimport static rx.Observable.just;%0A%0Aimport org.junit.Test;%0A%0Aimport rx.Subscriber;%0A%0Apublic class OperatorBufferingSyncBiasedTest %7B%0A%0A    @Test%0A    public void test() %7B%0A        %0A        just(1)%0A        //%0A        .lift(new OperatorBufferingSyncBiased%3CInteger%3E(1))%0A        //%0A                .subscribe(new Subscriber%3CInteger%3E() %7B%0A%0A                    @Override%0A                    public void onStart() %7B%0A                        request(1);%0A                    %7D%0A%0A                    @Override%0A                    public void onCompleted() %7B%0A                        System.out.println(%22completed%22);%0A                    %7D%0A%0A                    @Override%0A                    public void onError(Throwable e) %7B%0A                        e.printStackTrace();%0A                    %7D%0A%0A                    @Override%0A                    public void onNext(Integer t) %7B%0A                        System.out.println(t);%0A                    %7D%0A                %7D);%0A    %7D%0A%7D%0A

add test