View gh-check
#!/usr/bin/python3 | |
import asyncio | |
import time | |
import socket | |
import argparse | |
import aiohttp | |
class MyConnector(aiohttp.TCPConnector): |
View trial.key
Beyond Compare 4 | |
Licensed to: ASIO Allsoftinone | |
Quantity: 1 user | |
Serial number: 1822-9597 | |
License type: Pro Edition for Windows | |
--- BEGIN LICENSE KEY --- | |
H1bJTd2SauPv5Garuaq0Ig43uqq5NJOEw94wxdZTpU-pFB9GmyPk677gJ | |
vC1Ro6sbAvKR4pVwtxdCfuoZDb6hJ5bVQKqlfihJfSYZt-xVrVU27+0Ja | |
hFbqTmYskatMTgPyjvv99CF2Te8ec+Ys2SPxyZAF0YwOCNOWmsyqN5y9t |
View use-bbdiff
git config --global diff.tool bbdiff | |
git config --global difftool.bbdiff.cmd 'bbdiff --wait --resume "$LOCAL" "$REMOTE"' | |
git config --global difftool.prompt false | |
git config --global merge.tool bbdiff | |
git config --global mergetool.bbdiff.cmd 'bbdiff --wait --resume "$LOCAL" "$REMOTE"' | |
Double check ~/.gitconfig |
View RxBus2.java
// @yokeyword's Rxbus is here: https://github.com/YoKeyword/RxBus/blob/master/rxbus/src/main/java/me/yokeyword/rxbus/RxBus.java | |
package com.example.myproduct.lib.common.utils.rx.eventbus; | |
import java.util.Map; | |
import java.util.concurrent.ConcurrentHashMap; | |
import io.reactivex.Flowable; | |
import io.reactivex.processors.FlowableProcessor; |
View onErrorResumeNext.java
RxView.clicks(mIvTestGlide) // 只发出 onNext 事件的事件源 | |
.flatMap(new Function<Object, ObservableSource<Object>>() { | |
@Override | |
public ObservableSource<Object> apply(Object o) throws Exception { | |
// another observable which can throw onError. | |
return Observable.error(new Exception("模拟发生错误的地方!!!")) | |
.doOnError(new Consumer<Throwable>() { | |
@Override | |
public void accept(Throwable throwable) throws Exception { | |
// TODO : 由于下面的 onErrorResumeNext, 因此 error 事件无法传递到"订阅者 observer", 故需要在这里做处理. |