本文整理了Java中com.google.android.gms.tasks.Task.addOnCompleteListener()
方法的一些代码示例,展示了Task.addOnCompleteListener()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.addOnCompleteListener()
方法的具体详情如下:
包路径:com.google.android.gms.tasks.Task
类名称:Task
方法名:addOnCompleteListener
暂无
代码示例来源:origin: commonsguy/cw-omnibus
@SuppressLint("MissingPermission")
private void findLocation() {
FusedLocationProviderClient client=
LocationServices.getFusedLocationProviderClient(this);
client.getLastLocation()
.addOnCompleteListener(this, this::useResult)
.addOnFailureListener(this, this::copeWithFailure);
}
代码示例来源:origin: commonsguy/cw-omnibus
@Override
protected void onReady(Bundle state) {
if (state!=null) {
isInResolution=state.getBoolean(STATE_IN_RESOLUTION, false);
}
fragment=
(WeatherFragment)getSupportFragmentManager().findFragmentById(android.R.id.content);
if (fragment==null) {
fragment=new WeatherFragment();
getSupportFragmentManager().beginTransaction()
.add(android.R.id.content, fragment).commit();
}
if (!isInResolution) {
isInResolution=true;
LocationSettingsRequest request=new LocationSettingsRequest.Builder()
.addLocationRequest(LocationRequest.create())
.build();
LocationServices.getSettingsClient(this)
.checkLocationSettings(request)
.addOnCompleteListener(this::handleSettingsResponse);
}
}
代码示例来源:origin: commonsguy/cw-omnibus
@Override
protected void onReady(Bundle state) {
if (state!=null) {
isInResolution=state.getBoolean(STATE_IN_RESOLUTION, false);
}
fragment=
(WeatherFragment)getSupportFragmentManager().findFragmentById(android.R.id.content);
if (fragment==null) {
fragment=new WeatherFragment();
getSupportFragmentManager().beginTransaction()
.add(android.R.id.content, fragment).commit();
}
client=LocationServices.getFusedLocationProviderClient(this);
if (!isInResolution) {
isInResolution=true;
LocationSettingsRequest request=new LocationSettingsRequest.Builder()
.addLocationRequest(buildLocationRequest())
.build();
LocationServices.getSettingsClient(this)
.checkLocationSettings(request)
.addOnCompleteListener(this::handleSettingsResponse);
}
}
代码示例来源:origin: googlemaps/android-samples
if (mLocationPermissionGranted) {
Task<Location> locationResult = mFusedLocationProviderClient.getLastLocation();
locationResult.addOnCompleteListener(this, new OnCompleteListener<Location>() {
@Override
public void onComplete(@NonNull Task<Location> task) {
代码示例来源:origin: chat-sdk/chat-sdk-android
public Completable updateFirebaseUser () {
return Completable.create(e -> {
final FirebaseUser user = FirebaseAuth.getInstance().getCurrentUser();
UserProfileChangeRequest.Builder builder = new UserProfileChangeRequest.Builder()
.setDisplayName(model.getName());
if(model.getAvatarURL() != null && model.getAvatarURL().length() > 0) {
builder.setPhotoUri(Uri.parse(model.getAvatarURL()));
}
final UserProfileChangeRequest changeRequest = builder.build();
user.updateProfile(changeRequest).addOnCompleteListener(task -> e.onComplete());
}).subscribeOn(Schedulers.single());
}
代码示例来源:origin: chat-sdk/chat-sdk-android
FirebaseAuth.getInstance().signInWithEmailAndPassword(details.username, details.password).addOnCompleteListener(resultHandler);
break;
case Register:
FirebaseAuth.getInstance().createUserWithEmailAndPassword(details.username, details.password).addOnCompleteListener(resultHandler);
break;
case Anonymous:
FirebaseAuth.getInstance().signInAnonymously().addOnCompleteListener(resultHandler);
break;
case Custom:
FirebaseAuth.getInstance().signInWithCustomToken(details.token).addOnCompleteListener(resultHandler);
break;
代码示例来源:origin: chat-sdk/chat-sdk-android
public Completable sendPasswordResetMail(final String email) {
return Completable.create(
emitter->{
OnCompleteListener<Void> resultHandler = task->{
if (task.isSuccessful()) {
emitter.onComplete();
} else {
emitter.onError(getFirebaseError(DatabaseError.fromException(task.getException())));
}
};
FirebaseAuth.getInstance().sendPasswordResetEmail(email).addOnCompleteListener(resultHandler);
}).subscribeOn(Schedulers.single());
}
代码示例来源:origin: googlemaps/android-samples
Task<PlaceLikelihoodBufferResponse> placeResult =
mPlaceDetectionClient.getCurrentPlace(null);
placeResult.addOnCompleteListener
(new OnCompleteListener<PlaceLikelihoodBufferResponse>() {
@Override
代码示例来源:origin: chat-sdk/chat-sdk-android
public Completable signInWithCredential (final Activity activity, final AuthCredential credential) {
return Completable.create(e -> FirebaseAuth.getInstance().signInWithCredential(credential)
.addOnCompleteListener(activity, task -> {
if (task.isSuccessful() && task.isComplete()) {
FirebaseUser user = FirebaseAuth.getInstance().getCurrentUser();
FirebaseAuthenticationHandler handler = (FirebaseAuthenticationHandler) ChatSDK.auth();
handler.authenticateWithUser(user).subscribe(e::onComplete, e::onError);
}
else {
e.onError(task.getException());
}
}));
}
代码示例来源:origin: chat-sdk/chat-sdk-android
@Override
public Completable changePassword(String email, String oldPassword, final String newPassword) {
return Completable.create(
emitter->{
FirebaseUser user = FirebaseAuth.getInstance().getCurrentUser();
OnCompleteListener<Void> resultHandler = task->{
if (task.isSuccessful()) {
emitter.onComplete();
} else {
emitter.onError(getFirebaseError(DatabaseError.fromException(task.getException())));
}
};
user.updatePassword(newPassword).addOnCompleteListener(resultHandler);
})
.subscribeOn(Schedulers.single());
}
代码示例来源:origin: firebase/snippets-android
public void delete() {
// [START auth_fui_delete]
AuthUI.getInstance()
.delete(this)
.addOnCompleteListener(new OnCompleteListener<Void>() {
@Override
public void onComplete(@NonNull Task<Void> task) {
// ...
}
});
// [END auth_fui_delete]
}
代码示例来源:origin: FrangSierra/RxFirebase
public static <T> void assignOnTask(CompletableEmitter completableEmitter, Task<T> task) {
RxCompletableHandler handler = new RxCompletableHandler(completableEmitter);
task.addOnFailureListener(handler);
task.addOnSuccessListener(handler);
try {
task.addOnCompleteListener(handler);
} catch (Throwable t) {
// ignore
}
}
代码示例来源:origin: FrangSierra/RxFirebase
public static <T> void assignOnTask(MaybeEmitter<? super T> emitter, Task<T> task) {
RxHandler handler = new RxHandler(emitter);
task.addOnSuccessListener(handler);
task.addOnFailureListener(handler);
try {
task.addOnCompleteListener(handler);
} catch (Throwable t) {
// ignore
}
}
代码示例来源:origin: nmoskalenko/RxFirebase
public static <T> void assignOnTask(Subscriber<? super T> observer, Task<T> task) {
RxTask handler = new RxTask(observer);
task.addOnSuccessListener(handler);
task.addOnFailureListener(handler);
try {
task.addOnCompleteListener(handler);
} catch (Throwable t) {
// ignore
}
}
代码示例来源:origin: FrangSierra/RxFirebase
static <T> void setupTask(Task<T> task) {
when(task.addOnCompleteListener(testOnCompleteListener.capture())).thenReturn(task);
when(task.addOnSuccessListener(testOnSuccessListener.capture())).thenReturn(task);
when(task.addOnFailureListener(testOnFailureListener.capture())).thenReturn(task);
}
代码示例来源:origin: nmoskalenko/RxFirebase
private <T> void setupTask(Task<T> task) {
when(task.addOnCompleteListener(testOnCompleteListener.capture())).thenReturn(task);
when(task.addOnSuccessListener(testOnSuccessListener.capture())).thenReturn(task);
when(task.addOnFailureListener(testOnFailureListener.capture())).thenReturn(task);
}
代码示例来源:origin: nmoskalenko/RxFirebase
private <T> void setupTask(Task<T> task) {
when(task.addOnCompleteListener(testOnCompleteListener.capture())).thenReturn(task);
when(task.addOnSuccessListener(testOnSuccessListener.capture())).thenReturn(task);
when(task.addOnFailureListener(testOnFailureListener.capture())).thenReturn(task);
}
代码示例来源:origin: nmoskalenko/RxFirebase
@Before
public void setup() {
MockitoAnnotations.initMocks(this);
testOnCompleteListener = ArgumentCaptor.forClass(OnCompleteListener.class);
testOnSuccessListener = ArgumentCaptor.forClass(OnSuccessListener.class);
when(mockTask.addOnCompleteListener(testOnCompleteListener.capture())).thenReturn(mockTask);
when(mockTask.addOnSuccessListener(testOnSuccessListener.capture())).thenReturn(mockTask);
when(mockConfig.fetch()).thenReturn(mockTask);
when(mockConfig.fetch(1)).thenReturn(mockTask);
}
代码示例来源:origin: nmoskalenko/RxFirebase
@Before
public void setup() {
MockitoAnnotations.initMocks(this);
testOnCompleteListener = ArgumentCaptor.forClass(OnCompleteListener.class);
testOnSuccessListener = ArgumentCaptor.forClass(OnSuccessListener.class);
when(mockTask.addOnCompleteListener(testOnCompleteListener.capture())).thenReturn(mockTask);
when(mockTask.addOnSuccessListener(testOnSuccessListener.capture())).thenReturn(mockTask);
when(httpsCallableReference.call()).thenReturn(mockTask);
when(httpsCallableReference.call(any())).thenReturn(mockTask);
when(mockFunctions.getHttpsCallable(anyString())).thenReturn(httpsCallableReference);
}
代码示例来源:origin: owntracks/android
@SuppressWarnings("unused")
@Subscribe(sticky = true)
public void onEvent(Events.PermissionGranted event) {
Timber.v("location permission granted");
removeGeofences();
setupGeofences();
try {
Timber.v("Getting last location");
mFusedLocationClient.getLastLocation().addOnCompleteListener(this);
} catch (SecurityException ignored) {
}
}
内容来源于网络,如有侵权,请联系作者删除!