Реактивная поддержка потоков для комнаты

Question

Подписчик не получает никаких данных от Flowable.Ни onNext (), ни onError () не вызываются.Но когда org.reactivestreams.Subscriber был заменен на io.reactivex.functions.Consumer, он отлично работает.

repository.getAgentInfo()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new org.reactivestreams.Subscriber<AgentInfo>() {
    @Override
    public void onSubscribe(Subscription s) {
    Log.d("onSubscribe()", s.toString());
    }

    @Override
    public void onNext(AgentInfo agentInfo) {
    Log.d("onNext()", agentInfo.toString());
    }

    @Override
    public void onError(Throwable t) {
    Log.d("onError()", t.getLocalizedMessage());
    }

    @Override
    public void onComplete() {
    Log.d("onComplete()", "");
    }
});

@Dao
public interface FeedbackDao {

@Query("SELECT * FROM PartnerInfoEntity LIMIT 1")
Flowable<AgentInfoInfoEntity> getAgentInfo();

@Insert(onConflict = OnConflictStrategy.REPLACE)
void inserntAgentInfo(AgentInfoInfoEntity agentInfoEntity);

}

Пожалуйста, объясните мне, почему он не работает с подписчиком