在我的代码库中有几种情况,我订阅的流只会发出一个结果,因此使用 rx.Single 而不是 rx.Observable 是有意义的。 documentation对于 Single 表示以下内容:
A Single will call only one of these methods, and will only call it once. Upon calling either method, the Single terminates and the subscription to it ends.
使用传统的 Observable 我捕获对订阅的引用,以便我可以在适当的时间取消订阅而不会导致内存泄漏:
Subscription s = getObservable().subscribe(...);
subscriptions.add(s);
subscriptions.clear();
我的问题是这对于 Single 是否有必要,或者由于订阅立即结束这一事实是否可以简单地保留为:
getSingle.subscribe(...);
不会对订阅者的引用产生任何负面影响。
最佳答案
Single 不会告诉您有关多长时间它将运行的任何信息。
由于您的目标是 Android,所以答案是是,您应该保留订阅并取消订阅。
假设您正在切换 Fragments/Activities,并且调用了长时间运行的 SingleSubscribers onSuccess。所以最好的时间和空间大概是在onPause(),但是要看你的上下文。
如果您不退订,您可能会遇到 NullPinterExceptions、适配器被多次填充或类似问题。
关于android - 在 RxJava 中取消订阅 rx.Single,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37776004/
最近因为项目需要,需要将Android手机系统自带的某个系统软件反编译并更改里面某个资源,并重新打包,签名生成新的自定义的apk,下面我来介绍一下我的实现过程。APK修改,分为以下几步:反编译解包,修改,重打包,修改签名等步骤。安卓apk修改准备工作1.系统配置好JavaJDK环境变量2.需要root权限的手机(针对系统自带apk,其他软件免root)3.Auto-Sign签名工具4.apktool工具安卓apk修改开始反编译本文拿Android系统里面的Settings.apk做demo,具体如何将apk获取出来在此就不过多介绍了,直接进入主题:按键win+R输入cmd,打开命令窗口,并将路
我在我的RubyonRails应用程序中使用ActiveRecord::Store模块时遇到了一个奇怪的问题。据我了解,该模块在后台使用“序列化”方法,因此它只是使用ruby内置的psychgem将您的数据序列化为yaml格式。大多数时候它工作正常,但有时我会收到500错误并显示以下消息:LoadError(cannotloadsuchfile--enc/trans/single_byte):~/.rbenv/versions/1.9.3-p286/lib/ruby/1.9.1/psych/visitors/emitter.rb:27:in`write'~/.rbenv/versi
我正在编写一个将服务器端事件与ActionController::Live结合使用的应用程序。它正在使用puma应用程序服务器。当用户连接等待来自Redis的消息时,消息Controller中的方法保持事件状态。问题是我不想通过这种方法连接到Postgres。我在六个选项卡中打开应用程序后,它有超过五个连接,由config/database.yml文件中的池大小定义,应用程序崩溃。无论如何,在调用该方法时是否可以告诉我的应用它不需要连接到数据库,因为其中没有ActiveRecord查询调用? 最佳答案 一种可能的方法是使用中间件。设
将stripe的API与RubyonRails结合使用我无法保存订阅。我能够检索、更新和保存客户对象:customer=Stripe::Customer.retrieve(some_customer_id)#thisworkscustomer.save#thisworks我还可以检索订阅:subscription=customer.subscriptions.retrieve("some_subscription_id")#这个有效但是,在尝试保存订阅时:subscription.save#这不起作用我不断得到这个:NoMethodError:undefinedmethod`save'
我有一个模型依赖于一个单独的、联合的模型。classMagazine图像是多态的,可以附加到许多对象(页面和文章),而不仅仅是杂志。杂志需要在相关图像发生任何变化时自行更新该杂志还保存了一张自己的截图,可用于宣传:classMagazine现在如果图像发生变化,杂志也需要更新其截图。所以杂志真的需要知道图片什么时候出了问题。所以我们可以天真地直接从封面图片触发屏幕截图更新classImage...但是图片不应该代表杂志做事然而,图片可以用于许多不同的对象,实际上不应该对杂志进行特定的操作,因为这不是图片的责任。该图像也可能附加到页面或文章,并且不需要为它们做各种事情。“正常”的rail
在ruby中,我如何解码c风格的转义序列?例如'\n'到换行符,'\t'到制表符? 最佳答案 好吧,如果你不喜欢eval解决方案,我已经在Ruby中破解了一个简单的状态机来正确解析字符串中的简单“\n”和“\t”,包括预转义反斜杠本身。在这里:BACKSLASH="\\"defunescape_c_string(s)state=0res=''s.each_char{|c|casestatewhen0casecwhenBACKSLASHthenstate=1elseres这个可以轻松扩展以支持更多字符,包括多字符实体,如\123。
在ruby中,有没有办法在变量或常量定义后“取消定义”?在我们的rails环境中,我们将三个常量之一定义为true,具体取决于环境:TESTING、DEVELOPMENT或生产。然后,在Controller代码中,我们使用defined?来查看我们是否处于什么环境中,即:defined?制作。现在,我想对某些特定于环境的行为进行单元测试。我最初的尝试是在我的测试中设置适当的常量,然后在拆卸时重置它们。但是,我不知道如何重置DEVELOPMENT和PRODUCTION以便defined?返回false。显然,解决方案是除了检查适当的常量是否已定义之外,还检查它是否也为真,但这将导致不
我在使用ActionCable时遇到问题,每当我运行我的程序时,我都会收到一条错误消息,提示SubscriptionClassnotfoundConversationChannel当我尝试发送消息时,我得到了这个日志SuccessfullyupgradedtoWebSocket(REQUEST_METHOD:GET,HTTP_CONNECTION:Upgrade,HTTP_UPGRADE:websocket)Subscriptionclassnotfound:"ConversationChannel"Couldnotexecutecommandfrom{"command"=>"mess
我目前一直在研究如何根据我们想要的每个条件来分离CanCan的角色。在我们的应用程序中,有很多类别(例如数学、英语、历史等),每个类别中都有很多类(class)。每个用户可以在每个类别中扮演许多不同的角色。例如,约翰可以是数学的“读者”,这意味着他可以阅读所有数学类(class)。约翰也可以是英语的“作家”,这意味着他可以阅读所有英语类(class),在类别英语中创建类(class),并仅编辑/删除他创建的英语类(class)。如果这些是John仅有的角色,他将无法在导航栏中看到类别历史记录,并且将被拒绝访问历史记录中的类(class)。这些是关系的建立方式:classUser在mod
我正在尝试使用AMQP、Websockets和Ruby构建一个简单的聊天应用程序。我知道这可能不是理解AMQP的最佳用例,但我想了解我哪里出错了。以下是我的amqp-server代码require'rubygems'require'amqp'require'mongo'require'em-websocket'require'json'classMessageParser#messageformat=>"room:harry_potter,nickname:siddharth,room:members"defself.parse(message)parsed_message=JSON.