Binaries and dependency information for Maven, Ivy, Gradle and others can be found at http://search.maven.org.
AngelHack Hackathon Seoul, June 2019
The Pitch
Greeting
안녕하세요! (annyeonghaseyo!) Hello guys!
Quick Intro
Last year more than 10,000 buildings were destroyed because of natural disasters in California.
In Korea 1,000 buildings were destroyed 2 years ago.
20% could resist if maintained properly. Well-timed condition assessment and repair is required to protect against failures.
We’ve done some research on building condition assessment techniques and target to optimize the visual based ones.
Solution
Our mobile application allows to take a photo of the building or its part – a wall for example, and analyses the photo to
estimate the risk of the building to crash during an earthquake or a hurricane.
We use some basic plate tectonics knowledge, climate knowledge, as well as historical data tied to a particular location or area to estimate the challenge a building may have to resist.
For buildings at risk our platform allows to organize funding to repair it. The funding process is maintained transparent by keeping all the transactions in the open distributed ledger.
Our next steps include applying to related government programs and cooperation with insurance companies.
We continue our work to improve the platform usability, quality of assessment and scope of appliance.
Our team is an international multi-language speaking team. It combines creativity,
experience and unique set of connections from korean and european spots required to develop the prototyped idea to the next level.
Thank you. 고맙습니다 (gomabseubnida).
20% of the buildings designed to resist to a particular level of external
influence fail because of aging.
- Take a picture of a wall
- Sponsorship request Page
- Upload Building Address
- Upload Building Photo
- Upload Building Address
- Donation page ( Donate or Matching company for repair the building )
- Setting Page ( Modifying user information )
RxKotlin is a lightweight library that adds convenient extension functions to RxJava. You can use RxJava with Kotlin out-of-the-box, but Kotlin has language features (such as extension functions) that can streamline usage of RxJava even more. RxKotlin aims to conservatively collect these conveniences in one centralized library, and standardize conventions for using RxJava with Kotlin.
import io.reactivex.rxkotlin.subscribeBy
import io.reactivex.rxkotlin.toObservable
fun main(args: Array<String>) {
val list = listOf("Alpha", "Beta", "Gamma", "Delta", "Epsilon")
list.toObservable() // extension function for Iterables
.filter { it.length >= 5 }
.subscribeBy( // named arguments for lambda Subscribers
onNext = { println(it) },
onError = { it.printStackTrace() },
onComplete = { println("Done!") }
)
}
Since Kotlin makes it easy to implement extensions for anything and everything, this project has to be conservative in what features are in scope. Intentions to create syntactic sugar can quickly regress into syntactic saccharin, and such personal preferences belong in one's internal domain rather than an OSS library.
Here are some basic guidelines to determine whether your contribution might be in scope for RxKotlin:
-
Is this intended feature already in RxJava?
- If no, propose the operator in RxJava.
- If yes, can Kotlin streamline the operator further?
-
Does this substantially reduce the amount of boilerplate code?
-
Does this make an existing operator easier to use?
-
Does RxJava not contain this feature due to Java language limitations, or because of a deliberate decision to not include it?
Join us on the #rx channel in Kotlin Slack!
https://kotlinlang.slack.com/messages/rx
Use RxKotlin 1.x versions to target RxJava 1.x.
Use RxKotlin 2.x versions to target RxJava 2.x.
The maintainers do not update the RxJava dependency version for every RxJava release, so you should explicitly add the desired RxJava dependency version to your pom.xml
or build.gradle
.
Example for Maven:
<dependency>
<groupId>io.reactivex.rxjava2</groupId>
<artifactId>rxkotlin</artifactId>
<version>2.x.y</version>
</dependency>
and for Gradle:
implementation 'io.reactivex.rxjava2:rxkotlin:x.y.z'
Example for Maven:
<dependency>
<groupId>io.reactivex</groupId>
<artifactId>rxkotlin</artifactId>
<version>1.x.y</version>
</dependency>
and for Gradle:
implementation 'io.reactivex:rxkotlin:x.y.z'
You can also use Gradle or Maven with JitPack to build directly off a snapshot, branch, or commit of this repository.
For example, to build off the 2.x branch, use this setup for Gradle:
repositories {
maven { url 'https://jitpack.io' }
}
dependencies {
implementation 'com.github.ReactiveX:RxKotlin:2.x-SNAPSHOT'
}
Use this setup for Maven:
<repositories>
<repository>
<id>jitpack.io</id>
<url>https://jitpack.io</url>
</repository>
</repositories>
<dependency>
<groupId>com.github.ReactiveX</groupId>
<artifactId>RxKotlin</artifactId>
<version>2.x-SNAPSHOT</version>
</dependency>
Learn more about building this project with JitPack here.
Target Type | Method | Return Type | Description |
---|---|---|---|
BooleanArray | toObservable() | Observable | Turns a Boolean array into an Observable |
ByteArray | toObservable() | Observable | Turns a Byte array into an Observable |
ShortArray | toObservable() | Observable | Turns a Short array into an Observable |
IntArray | toObservable() | Observable | Turns an Int array into an Observable |
LongArray | toObservable() | Observable | Turns a Long array into an Observable |
FloatArray | toObservable() | Observable | Turns a Float array into an Observable |
DoubleArray | toObservable() | Observable | Turns a Double array into an Observable |
Array | toObservable() | Observable | Turns a T array into an Observable |
IntProgression | toObservable() | Observable | Turns an IntProgression into an Observable |
Iterable | toObservable() | Observable | Turns an Iterable<T> into an Observable |
Iterator | toObservable() | Observable | Turns an Iterator<T> into an Observable |
Observable | flatMapSequence() | Observable | Flat maps each T emission to a Sequence<R> |
Observable<Pair<A,B>> | toMap() | Single<Map<A,B>> | Collects Pair<A,B> emissions into a Map<A,B> |
Observable<Pair<A,B>> | toMultimap() | Single<Map<A, List<B>> |
Collects Pair<A,B> emissions into a Map<A,List<B>> |
Observable<Observable> | mergeAll() | Observable | Merges all Observables emitted from an Observable |
Observable<Observable> | concatAll() | Observable | Concatenates all Observables emitted from an Observable |
Observable<Observable> | switchLatest() | Observable | Emits from the last emitted Observable |
Observable<*> | cast() | Observable | Casts all emissions to the reified type |
Observable<*> | ofType() | Observable | Filters all emissions to only the reified type |
Iterable<Observable> | merge() | Observable | Merges an Iterable of Observables into a single Observable |
Iterable<Observable> | mergeDelayError() | Observable | Merges an Iterable of Observables into a single Observable, but delays any error |
BooleanArray | toFlowable() | Flowable | Turns a Boolean array into an Flowable |
ByteArray | toFlowable() | Flowable | Turns a Byte array into an Flowable |
ShortArray | toFlowable() | Flowable | Turns a Short array into an Flowable |
IntArray | toFlowable() | Flowable | Turns an Int array into an Flowable |
LongArray | toFlowable() | Flowable | Turns a Long array into an Flowable |
FloatArray | toFlowable() | Flowable | Turns a Float array into an Flowable |
DoubleArray | toFlowable() | Flowable | Turns a Double array into an Flowable |
Array | toFlowable() | Flowable | Turns a T array into an Flowable |
IntProgression | toFlowable() | Flowable | Turns an IntProgression into an Flowable |
Iterable | toFlowable() | Flowable | Turns an Iterable<T> into an Flowable |
Iterator | toFlowable() | Flowable | Turns an Iterator<T> into an Flowable |
Flowable | flatMapSequence() | Flowable | Flat maps each T emission to a Sequence<R> |
Flowable<Pair<A,B>> | toMap() | Single<Map<A,B>> | Collects Pair<A,B> emissions into a Map<A,B> |
Flowable<Pair<A,B>> | toMultimap() | Single<Map<A, List<B>>> |
Collects Pair<A,B> emissions into a Map<A,List<B>> |
Flowable<Flowable> | mergeAll() | Flowable | Merges all Flowables emitted from an Flowable |
Flowable<Flowable> | concatAll() | Flowable | Concatenates all Flowables emitted from an Flowable |
Flowable<Flowable> | switchLatest() | Flowable | Emits from the last emitted Flowable |
Flowable | cast() | Flowable | Casts all emissions to the reified type |
Flowable | ofType() | Flowable | Filters all emissions to only the reified type |
Iterable<Flowable> | merge() | Flowable | Merges an Iterable of Flowables into a single Flowable |
Iterable<Flowable> | mergeDelayError() | Flowable | Merges an Iterable of Flowables into a single Flowable, but delays any error |
Single | cast() | Single | Casts all emissions to the reified type |
Observable<Single> | mergeAllSingles() | Observable | Merges all Singles emitted from an Observable |
Flowable<Single> | mergeAllSingles() | Flowable | Merges all Singles emitted from a Flowable |
Maybe | cast() | Maybe | Casts any emissions to the reified type |
Maybe | ofType() | Maybe | Filters any emission that is the reified type |
Observable<Maybe> | mergeAllMaybes() | Observable | Merges all emitted Maybes |
Flowable<Maybe> | mergeAllMaybes() | Flowable | Merges all emitted Maybes |
Action | toCompletable() | Completable | Turns an Action into a Completable |
Callable | toCompletable() | Completable | Turns a Callable into a Completable |
Future | toCompletable() | Completable | Turns a Future into a Completable |
(() -> Any) | toCompletable() | Completable | Turns a (() -> Any) into a Completable |
Observable | mergeAllCompletables() | Completable> | Merges all emitted Completables |
Flowable | mergeAllCompletables() | Completable | Merges all emitted Completables |
Observable | subscribeBy() | Disposable | Allows named arguments to construct an Observer |
Flowable | subscribeBy() | Disposable | Allows named arguments to construct a Subscriber |
Single | subscribeBy() | Disposable | Allows named arguments to construct a SingleObserver |
Maybe | subscribeBy() | Disposable | Allows named arguments to construct a MaybeObserver |
Completable | subscribeBy() | Disposable | Allows named arguments to construct a CompletableObserver |
Observable | blockingSubscribeBy() | Unit | Allows named arguments to construct a blocking Observer |
Flowable | blockingSubscribeBy() | Unit | Allows named arguments to construct a blocking Subscriber |
Disposable | addTo() | Disposable | Adds a Disposable to the specified CompositeDisposable |
CompositeDisposable | plusAssign() | Disposable | Operator function to add a Disposable to thisCompositeDisposable |
To help cope with the SAM ambiguity issue when using RxJava 2.x with Kotlin, there are a number of helper factories and extension functions to workaround the affected operators.
Observables.zip()
Observables.combineLatest()
Observable#zipWith()
Observable#withLatestFrom()
Flowables.zip()
Flowables.combineLatest()
Flowable#zipWith()
Flowable#withLatestFrom()
Singles.zip()
Single#zipWith()
Maybes.zip()
RxKotlin can be used in conjunction with other Rx and Kotlin libraries, such as RxAndroid, RxBinding, and TornadoFX/RxKotlinFX. These libraries and RxKotlin are modular, and RxKotlin is merely a set of extension functions to RxJava that can be used with these other libraries. There should be no overlap or dependency issues.