我正在尝试使用 OperationQueue 和 Operation 在 Firebase 中创建用户。我将 Firebase Auth 调用放在操作主方法中。即使在 Firebase 注册过程成功之前,也会触发操作的完成块。
RegistrationViewModal.swift
2 3 4 5 6 7 8 9 10 11 12 13 | let operationQueues = OperationQueues() let registrationRecord = RegistrationRecord(user: self.user!, encryptedData: self.fireBaseAuthCompliance) let userRegistrationOperation = UserRegistrationOperation(registrationRecord: registrationRecord) userRegistrationOperation.completionBlock = { //I am expecting this completion block will be called only when my firebase invocation in main() method is finished DispatchQueue.main.async { //Since this block is getting triggered even before completion, the //value is returning as null self.user?.uid = userRegistrationOperation.registrationRecord.user.uid } } operationQueues.userRegistrationQueue.addOperation(userRegistrationOperation) |
UserRegistrationOperation.swift
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 | lazy var userRegistrationQueue: OperationQueue = { var queue = OperationQueue() queue.maxConcurrentOperationCount = 1 queue.name ="User registration queue" return queue }() } class UserRegistrationOperation: Operation { var registrationRecord: RegistrationRecord init(registrationRecord: RegistrationRecord) { self.registrationRecord = registrationRecord } override func main() { guard !isCancelled else { return } self.registrationRecord.state = RegistrationStatus.pending //Firebase invocation to create a user in Firebase Auth Auth.auth().createUser(withEmail: self.registrationRecord.user.userEmail, password: self.registrationRecord.encryptedData){ [weak self](result, error) in if error != nil { print("Error occured while user registration process") self?.registrationRecord.state = RegistrationStatus.failed return } self?.registrationRecord.user.uid = result?.user.uid self?.registrationRecord.state = RegistrationStatus.processed } } } |
问题是你的操作正在启动一个异步进程,但是在异步任务启动时操作完成,而不是在异步任务完成时完成。
你需要做与a€?concurrenta€?相关的KVO?操作,如文档中所述:
If you are creating a concurrent operation, you need to override the following methods and properties at a minimum:
start() isAsynchronous isExecuting isFinished In a concurrent operation, your
start() method is responsible for starting the operation in an asynchronous manner. Whether you spawn a thread or call an asynchronous function, you do it from this method. Upon starting the operation, yourstart() method should also update the execution state of the operation as reported by theisExecuting property. You do this by sending out KVO notifications for theisExecuting key path, which lets interested clients know that the operation is now running. YourisExecuting property must also provide the status in a thread-safe manner.Upon completion or cancellation of its task, your concurrent operation object must generate KVO notifications for both the
isExecuting andisFinished key paths to mark the final change of state for your operation. (In the case of cancellation, it is still important to update theisFinished key path, even if the operation did not completely finish its task. Queued operations must report that they are finished before they can be removed from a queue.) In addition to generating KVO notifications, your overrides of theisExecuting andisFinished properties should also continue to report accurate values based on the state of your operation.
现在所有这些听起来都令人毛骨悚然,但实际上并没有那么糟糕。一种方法是编写一个处理所有这些 KVO 内容的基本操作类,这个答案概述了一个示例实现。
然后你可以继承
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 | var registrationRecord: RegistrationRecord init(registrationRecord: RegistrationRecord) { self.registrationRecord = registrationRecord super.init() // whenever you subclass, remember to call `super` } override func main() { self.registrationRecord.state = .pending //Firebase invocation to create a user in Firebase Auth Auth.auth().createUser(withEmail: registrationRecord.user.userEmail, password: registrationRecord.encryptedData) { [weak self] result, error in defer { self?.finish() } // make sure to call `finish` regardless of how we leave this closure guard let result = result, error == nil else { print("Error occured while user registration process") self?.registrationRecord.state = .failed return } self?.registrationRecord.user.uid = result.user.uid self?.registrationRecord.state = .processed } } } |
有很多方法可以实现
我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div
总的来说,我对ruby还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用
类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc
我正在尝试设置一个puppet节点,但rubygems似乎不正常。如果我通过它自己的二进制文件(/usr/lib/ruby/gems/1.8/gems/facter-1.5.8/bin/facter)在cli上运行facter,它工作正常,但如果我通过由rubygems(/usr/bin/facter)安装的二进制文件,它抛出:/usr/lib/ruby/1.8/facter/uptime.rb:11:undefinedmethod`get_uptime'forFacter::Util::Uptime:Module(NoMethodError)from/usr/lib/ruby
我想了解Ruby方法methods()是如何工作的。我尝试使用“ruby方法”在Google上搜索,但这不是我需要的。我也看过ruby-doc.org,但我没有找到这种方法。你能详细解释一下它是如何工作的或者给我一个链接吗?更新我用methods()方法做了实验,得到了这样的结果:'labrat'代码classFirstdeffirst_instance_mymethodenddefself.first_class_mymethodendendclassSecond使用类#returnsavailablemethodslistforclassandancestorsputsSeco
我在我的项目中添加了一个系统来重置用户密码并通过电子邮件将密码发送给他,以防他忘记密码。昨天它运行良好(当我实现它时)。当我今天尝试启动服务器时,出现以下错误。=>BootingWEBrick=>Rails3.2.1applicationstartingindevelopmentonhttp://0.0.0.0:3000=>Callwith-dtodetach=>Ctrl-CtoshutdownserverExiting/Users/vinayshenoy/.rvm/gems/ruby-1.9.3-p0/gems/actionmailer-3.2.1/lib/action_mailer
设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline,但已经有几个月没有使用它了。现在,在Ruby1.9.2上全新安装时,它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗? 最佳答案
我已经从我的命令行中获得了一切,所以我可以运行rubymyfile并且它可以正常工作。但是当我尝试从sublime中运行它时,我得到了undefinedmethod`require_relative'formain:Object有人知道我的sublime设置中缺少什么吗?我正在使用OSX并安装了rvm。 最佳答案 或者,您可以只使用“require”,它应该可以正常工作。我认为“require_relative”仅适用于ruby1.9+ 关于ruby-主要:Objectwhenrun
我有一个具有一些属性的模型:attr1、attr2和attr3。我需要在不执行回调和验证的情况下更新此属性。我找到了update_column方法,但我想同时更新三个属性。我需要这样的东西:update_columns({attr1:val1,attr2:val2,attr3:val3})代替update_column(attr1,val1)update_column(attr2,val2)update_column(attr3,val3) 最佳答案 您可以使用update_columns(attr1:val1,attr2:val2
我不确定传递给方法的对象的类型是否正确。我可能会将一个字符串传递给一个只能处理整数的函数。某种运行时保证怎么样?我看不到比以下更好的选择:defsomeFixNumMangler(input)raise"wrongtype:integerrequired"unlessinput.class==FixNumother_stuffend有更好的选择吗? 最佳答案 使用Kernel#Integer在使用之前转换输入的方法。当无法以任何合理的方式将输入转换为整数时,它将引发ArgumentError。defmy_method(number)