cn.felord.retrofit.rxjava

Class CallEnqueueObservable.CallCallback<T>

java.lang.Object

cn.felord.retrofit.rxjava.CallEnqueueObservable.CallCallback<T>

All Implemented Interfaces:

io.reactivex.rxjava3.disposables.Disposable, retrofit2.Callback<T>

Enclosing class:

CallEnqueueObservable<T>

private static final class CallEnqueueObservable.CallCallback<T>
extends Object
implements io.reactivex.rxjava3.disposables.Disposable, retrofit2.Callback<T>

Field Summary

Fields

Modifier and Type	Field and Description
private retrofit2.Call<?>	call
private boolean	disposed
private io.reactivex.rxjava3.core.Observer<? super retrofit2.Response<T>>	observer
(package private) boolean	terminated

Constructor Summary

Constructors

Constructor and Description
CallCallback(retrofit2.Call<?> call, io.reactivex.rxjava3.core.Observer<? super retrofit2.Response<T>> observer)

Method Summary

Modifier and Type	Method and Description
void	dispose()
boolean	isDisposed()
void	onFailure(retrofit2.Call<T> call, Throwable t)
void	onResponse(retrofit2.Call<T> call, retrofit2.Response<T> response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.reactivex.rxjava3.disposables.Disposable

disposed, empty, fromAction, fromAutoCloseable, fromFuture, fromFuture, fromRunnable, fromSubscription, toAutoCloseable

Field Detail

call

private final retrofit2.Call<?> call

observer

private final io.reactivex.rxjava3.core.Observer<? super retrofit2.Response<T>> observer

disposed

private volatile boolean disposed

terminated

boolean terminated

Constructor Detail

CallCallback

CallCallback(retrofit2.Call<?> call,
             io.reactivex.rxjava3.core.Observer<? super retrofit2.Response<T>> observer)

Method Detail

onResponse

public void onResponse(retrofit2.Call<T> call,
                       retrofit2.Response<T> response)

Specified by:

onResponse in interface retrofit2.Callback<T>

onFailure

public void onFailure(retrofit2.Call<T> call,
                      Throwable t)

Specified by:

onFailure in interface retrofit2.Callback<T>

dispose

public void dispose()

Specified by:

dispose in interface io.reactivex.rxjava3.disposables.Disposable

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface io.reactivex.rxjava3.disposables.Disposable