Fix #704. Dependency updates

2017-03-11 16:00:07 +01:00
parent d8fa7bc9d2
commit b512c67b5d
5 changed files with 42 additions and 22 deletions
@@ -10,7 +10,7 @@ import rx.Subscription
 import java.util.concurrent.atomic.AtomicBoolean

 fun Call.asObservable(): Observable<Response> {
-    return Observable.create { subscriber ->
+    return Observable.unsafeCreate { subscriber ->
        // Since Call is a one-shot type, clone it for each new subscriber.
        val call = clone()