超好看鸭

RxJava的Observable订阅时如何作到在onComplete被调用时取消订阅？

例: table.subscribe(tableIns -> { // System.out.println("-------Information-------"); System.out.println(tableIns); }, throwable -> { throw new SchemaExportException(throwable); }, new Action() { @Override public void run() throws Exception { System.out.println("Complete"); // 在这里取消订阅 }); 注意：是非Android 运行环境, 使用的是RxJava2.x