Wsrtjtyk

I am trying to use Retrofit and RxJava to make an API call within a custom view in an app that I am working on, but I encounter an incompatible type error when trying to subscribe to the Observable from my Retrofit API call.

ApiService

public interface ApiService {

@GET("airline-tickets.php")

Observable<List<Ticket>> getStarredRepositories();

}

ApiClient

public class ApiClient {

private static final String GITHUB_BASE_URL = "https://api.androidhive.info/json/";

private ApiService apiService;

private static ApiClient instance;



public ApiClient() {

    final Retrofit retrofit = new Retrofit.Builder()

            .baseUrl(GITHUB_BASE_URL)

            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())

            .addConverterFactory(GsonConverterFactory.create())

            .build();

    apiService = retrofit.create(ApiService.class);

}



public static ApiClient getInstance() {

    if (instance == null) {

        instance = new ApiClient();

    }

    return instance;

}



public Observable<List<Ticket>> getStarredRepos() {

    return apiService.getStarredRepositories();

}

}

MainActivity

public class MainActivity extends AppCompatActivity {



private static final String TAG = MainActivity.class.getName();



@Override

protected void onCreate(Bundle savedInstanceState) {

    super.onCreate(savedInstanceState);

    setContentView(R.layout.activity_main);



    Subscription subscription= (Subscription) ApiClient.getInstance()

            .getStarredRepos()

            .subscribeOn(Schedulers.io())

            .observeOn(AndroidSchedulers.mainThread())

            .subscribe(new Observer<List<Ticket>>() {

                @Override

                public void onSubscribe(Disposable d) {



                }



                @Override

                public void onNext(List<Ticket> tickets) {



                }



                @Override

                public void onError(Throwable e) {



                }



                @Override

                public void onComplete() {



                }

            });

}

}

This part of code showing Inconvertible types; cannot cast 'void' to 'org.reactivestreams.Subscription

Subscription subscription= (Subscription) ApiClient.getInstance()

            .getStarredRepos()

            .subscribeOn(Schedulers.io())

            .observeOn(AndroidSchedulers.mainThread())

            .subscribe(new Observer<List<Ticket>>() {

                @Override

                public void onSubscribe(Disposable d) {



                }



                @Override

                public void onNext(List<Ticket> tickets) {



                }



                @Override

                public void onError(Throwable e) {



                }



                @Override

                public void onComplete() {



                }

            });

Use subscribeWith which returns Observer that you passed onto that method. You are probably using old RxJava 1 code. RxJava 2 API changed a bit. Observable now accepts Observer and you should change Subscription to Observer