@NonNull
private Observable<MjpegInputStream> connect(String url) {
/*this is line 84 */ return Observable.defer(() -> {
try {
HttpURLConnection urlConnection = (HttpURLConnection) new URL(url).openConnection();
InputStream inputStream = urlConnection.getInputStream();
switch (type) {
// handle multiple implementations
case DEFAULT:
return Observable.just(new MjpegInputStreamDefault(inputStream));
case NATIVE:
return Observable.just(new MjpegInputStreamNative(inputStream));
}
throw new IllegalStateException("invalid type");
} catch (IOException e) {
return Observable.error(e);
}
});
}