private static Flowable createData(final T t) {
return Flowable.create(new FlowableOnSubscribe() {
@OverRide
public void subscribe(FlowableEmitter emitter) throws Exception {
try {
emitter.onNext(t);
emitter.onComplete();
} catch (Exception e) {
emitter.onError(e);
}
}
}, BackpressureStrategy.BUFFER);
}