test_class.declarator: OTHER_USER = "otherUser"
test_class.modifier: private static final
test_class.original_string: private static final String OTHER_USER = "otherUser";
test_class.type: String
test_class.var_name: OTHER_USER
test_class.declarator: CURRENT_USER = "currentUser"
test_class.modifier: private static final
test_class.original_string: private static final String CURRENT_USER = "currentUser";
test_class.type: String
test_class.var_name: CURRENT_USER
test_class.declarator: mMockParseHelper
test_class.modifier: private
test_class.original_string: private ParseHelper mMockParseHelper;
test_class.type: ParseHelper
test_class.var_name: mMockParseHelper
test_class.declarator: mTarget
test_class.modifier: private
test_class.original_string: private ParseUserDataSource mTarget;
test_class.type: ParseUserDataSource
test_class.var_name: mTarget
test_class.file: ExampleApp/src/test/java/com/badoo/chateau/example/data/repos/user/ParseUserDataSourceTest.java
test_class.identifier: ParseUserDataSourceTest
test_class.superclass: extends BaseRxTestCase
test_case.body: @Test
      public void getAllUsers() {
          // Given
          List<ParseUser> users = ModelTestHelper.createParseUsers(10);
          when(mMockParseHelper.find(Mockito.<ParseQuery<ParseUser>>any())).thenReturn(Observable.just(users));
          ParseUser currentUser = ModelTestHelper.createParseUser(CURRENT_USER);
          when(mMockParseHelper.getCurrentUser()).thenReturn(currentUser);
  
          // When
          TestSubscriber<List<ExampleUser>> testSubscriber = executeTarget(mTarget.getAllUsers(new UserQueries.GetAllUsersQuery()));
  
          // Then
          assertThat(testSubscriber.getOnNextEvents().size(), is(1));
          testSubscriber.assertCompleted();
      }
test_case.class_method_signature: ParseUserDataSourceTest.getAllUsers()
test_case.full_signature: @Test public void getAllUsers()
test_case.identifier: getAllUsers
test_case.invocations: createParseUsers thenReturn when find any just createParseUser thenReturn when getCurrentUser executeTarget getAllUsers assertThat size getOnNextEvents is assertCompleted
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void getAllUsers()
focal_class.declarator: mParseHelper
focal_class.modifier: private
focal_class.original_string: private ParseHelper mParseHelper;
focal_class.type: ParseHelper
focal_class.var_name: mParseHelper
focal_class.file: ExampleApp/src/main/java/com/badoo/chateau/example/data/repos/user/ParseUserDataSource.java
focal_class.identifier: ParseUserDataSource
focal_class.interfaces: implements UserDataSource<ExampleUser>
focal_class.class_method_signature: ParseUserDataSource.ParseUserDataSource(@NonNull ParseHelper parseHelper)
focal_class.full_signature: public  ParseUserDataSource(@NonNull ParseHelper parseHelper)
focal_class.identifier: ParseUserDataSource
focal_class.modifiers: public
focal_class.parameters: (@NonNull ParseHelper parseHelper)
focal_class.signature:  ParseUserDataSource(@NonNull ParseHelper parseHelper)
focal_class.class_method_signature: ParseUserDataSource.getAllUsers(UserQueries.GetAllUsersQuery query)
focal_class.full_signature: @NonNull @Override public Observable<List<ExampleUser>> getAllUsers(UserQueries.GetAllUsersQuery query)
focal_class.identifier: getAllUsers
focal_class.modifiers: @NonNull @Override public
focal_class.parameters: (UserQueries.GetAllUsersQuery query)
focal_class.return: Observable<List<ExampleUser>>
focal_class.signature: Observable<List<ExampleUser>> getAllUsers(UserQueries.GetAllUsersQuery query)
focal_class.class_method_signature: ParseUserDataSource.getSingleUser(UserQueries.GetUserQuery query)
focal_class.full_signature: @NonNull @Override public Observable<ExampleUser> getSingleUser(UserQueries.GetUserQuery query)
focal_class.identifier: getSingleUser
focal_class.modifiers: @NonNull @Override public
focal_class.parameters: (UserQueries.GetUserQuery query)
focal_class.return: Observable<ExampleUser>
focal_class.signature: Observable<ExampleUser> getSingleUser(UserQueries.GetUserQuery query)
focal_method.body: @NonNull
      @Override
      public Observable<List<ExampleUser>> getAllUsers(UserQueries.GetAllUsersQuery query) {
          final ParseQuery<ParseUser> parseQuery = new ParseQuery<>("_User");
          parseQuery.whereNotEqualTo("objectId", mParseHelper.getCurrentUser().getObjectId());
          parseQuery.setCachePolicy(ParseQuery.CachePolicy.NETWORK_ONLY);
  
          return mParseHelper.find(parseQuery)
              .flatMap(Observable::from)
              .map(ParseUtils::fromParseUser)
              .toList()
              .subscribeOn(Schedulers.io());
      }
focal_method.class_method_signature: ParseUserDataSource.getAllUsers(UserQueries.GetAllUsersQuery query)
focal_method.full_signature: @NonNull @Override public Observable<List<ExampleUser>> getAllUsers(UserQueries.GetAllUsersQuery query)
focal_method.identifier: getAllUsers
focal_method.invocations: whereNotEqualTo getObjectId getCurrentUser setCachePolicy subscribeOn toList map flatMap find io
focal_method.modifiers: @NonNull @Override public
focal_method.parameters: (UserQueries.GetAllUsersQuery query)
focal_method.return: Observable<List<ExampleUser>>
focal_method.signature: Observable<List<ExampleUser>> getAllUsers(UserQueries.GetAllUsersQuery query)