package xdean.jex.extra.rx.op;

import org.junit.Test;

import rx.Observable;

public class TestFunctionOperator {

  @Test
  public void test() {
    Observable.range(0, 5)
        .lift(FunctionOperator.of(this::func))
        .test()
        .assertResult(0, -1, -2, -3, -4);
  }

  private Observable<Integer> func(Observable<Integer> ob) {
    return ob.map(i -> -i);
  }
}

@@ -117,16 +117,52 @@
 or %7B%0D%0A%0D%0A
+  @SuppressWarnings(%22deprecation%22)%0D%0A
   @Test%0D

resolve warning