@@ -367,48 +367,49 @@ class IMConversationTestCase: RTMBaseTestCase {
367367 }
368368
369369 func testServiceConversationSubscription( ) {
370- guard
371- let client = newOpenedClient ( ) ,
372- let serviceConversationID = IMConversationTestCase . newServiceConversation ( )
373- else
374- {
375- XCTFail ( )
376- return
370+ guard let client = newOpenedClient ( ) ,
371+ let serviceConversationID = IMConversationTestCase . newServiceConversation ( ) else {
372+ XCTFail ( )
373+ return
377374 }
378375
379376 delay ( )
380377
381378 var serviceConversation : IMServiceConversation ?
382379
383- let queryExp = expectation ( description: " conv query " )
384- try ! client. conversationQuery. getConversation ( by: serviceConversationID) { ( result) in
385- XCTAssertTrue ( result. isSuccess)
386- XCTAssertNil ( result. error)
387- serviceConversation = ( result. value as? IMServiceConversation )
388- queryExp. fulfill ( )
380+ expecting { ( exp) in
381+ try ! client. conversationQuery. getConversation ( by: serviceConversationID) { ( result) in
382+ XCTAssertTrue ( result. isSuccess)
383+ XCTAssertNil ( result. error)
384+ serviceConversation = ( result. value as? IMServiceConversation )
385+ XCTAssertEqual ( serviceConversation? . isSubscribed, false )
386+ exp. fulfill ( )
387+ }
389388 }
390- wait ( for: [ queryExp] , timeout: timeout)
391389
392- let checkExp = expectation ( description: " check subscription " )
393- checkExp. expectedFulfillmentCount = 3
394- serviceConversation? . checkSubscription ( completion: { ( result) in
395- XCTAssertTrue ( result. isSuccess)
396- XCTAssertNil ( result. error)
397- XCTAssertEqual ( result. value, false )
398- checkExp. fulfill ( )
399- try ! serviceConversation? . subscribe ( completion: { ( result) in
390+ expecting (
391+ description: " service conversation subscription " ,
392+ count: 3 )
393+ { ( exp) in
394+ serviceConversation? . checkSubscription ( completion: { ( result) in
400395 XCTAssertTrue ( result. isSuccess)
401396 XCTAssertNil ( result. error)
402- checkExp. fulfill ( )
403- serviceConversation? . checkSubscription ( completion: { ( result) in
397+ XCTAssertEqual ( result. value, false )
398+ exp. fulfill ( )
399+ try ! serviceConversation? . subscribe ( completion: { ( result) in
404400 XCTAssertTrue ( result. isSuccess)
405401 XCTAssertNil ( result. error)
406- XCTAssertEqual ( result. value, true )
407- checkExp. fulfill ( )
402+ XCTAssertEqual ( serviceConversation? . isSubscribed, true )
403+ exp. fulfill ( )
404+ serviceConversation? . checkSubscription ( completion: { ( result) in
405+ XCTAssertTrue ( result. isSuccess)
406+ XCTAssertNil ( result. error)
407+ XCTAssertEqual ( result. value, true )
408+ exp. fulfill ( )
409+ } )
408410 } )
409411 } )
410- } )
411- wait ( for: [ checkExp] , timeout: timeout)
412+ }
412413 }
413414
414415 func testNormalConversationUnreadEvent( ) {
0 commit comments