rx-java

    1热度

    1回答

    我是RxJava的新手。我的经验主要来自那些教程: Here和here。 现在,我发现自己处于一种与Retrofit2进行API调用的情况,该调用将返回Obesrvable<AccessToken>。客户端将如下调用这个服务: public Observable<TokenResult> authenticateWithClientCredentials() { return auth

    0热度

    1回答

    即时使用BehaviourourRelay作为源observable,我喜欢它会发出订阅时最后缓存的值,所以我不需要手动调用showPlayingState(mPlayStateManager.getCurrentState())。 但是这会带来一个问题,当我想在订阅中对动画做出反应时,因为我不想在这个缓存的发射中运行动画,当我在onCreate中订阅时,它会被命中,UI应该跳转到没有动画的状态到

    1热度

    2回答

    我正在研究将我的(Android)应用程序中的某些逻辑转换为使用RxJava,但是我正在努力想出一种方法来执行一些更高级的逻辑。 用例如下:我想向用户展示一种Feed。 Feed包含来自不同来源的项目,例如消息,文章等。由于API限制,应用程序本身必须收集各个资源并将其显示在一个列表中。是 例如,假设我在饲料项目如下: class FeedItem { Type feedItem; //

    2热度

    1回答

    什么是类Observable中的hide方法用于? 我读了文件,但仍然不知道它是干什么用的,我看到很多人使用它 hide() Hides the identity of this Observable and its Disposable. http://reactivex.io/RxJava/javadoc/io/reactivex/Observable.html 当我们应该用这种

    0热度

    2回答

    我有两个观测量定义,我如下美其名曰: Observable<Boolean> statusObser1 = reactiveApiConsumer.syncGradesSet1(subListDtos.get(0)); Observable<Boolean> statusObser2 = reactiveApiConsumer.syncGradesSet2(subListDtos.get(1))

    0热度

    1回答

    如果这是一个愚蠢的问题,我很抱歉,但是Firebase的android sdk已经是异步的了吗?我在以前的项目中使用过RxJava,并且发现有人将它与Firebase SDK一起使用。如果sdk已经是异步的,为什么会这样呢?谢谢。

    1热度

    1回答

    我使用干净的架构来处理android项目。 我有以下类: public abstract class RxBaseInteractor<T, Params> { private final CompositeDisposable disposables; public RxBaseInteractor() { this.disposables = new Comp

    0热度

    1回答

    我正在使用grpc-java,并有3个服务,A,B和C.我称服务A,然后服务A调用B和C.我在调用B和C时使用Hystrix。C又产生另一个线程拨打另一项服务。 我有围绕traceId传递的ClientInterceptors和ServerInterceptors。只要它是gRPC工作线程,我就可以在上下文和日志中看到traceIds,但在调用移动到另一个线程时会丢失它们 - RxIoSchedu

    1热度

    1回答

    我从服务器获取json格式的聊天列表。我把他们推到ChatsModel。此类中有userId字段,即在每个聊天中有该用户的userId。没有关于用户的其他信息。还有就是有关类型的用户信息的一个领域UserMessagesResponse 所以,在那个userMessagesResponse等于null 我聊天列表和userId之后开始时,我要送另一个请求获取有关信息用户。我这样做,是这样的:发生在

    0热度

    4回答

    请,有人可以给我解释一下什么是使用反应性风格的优点: Observable<String> greeting = Observable.just("Hello"); Observable<String> yelling = greeting.map(s -> s.toUppercase()); ,而不是简单的命令式风格: String greeting = "Hello"; String