rxjava observable

HotObservable.java

public class HotObservable implements Observable.OnSubscribe<String> {
        private final List<Subscriber<? super String>> subscribers =
                Collections.synchronizedList(new LinkedList<Subscriber<? super String>>());
        private final OkHttpClient client = new OkHttpClient.Builder()
                .readTimeout(0, TimeUnit.DAYS).build();
        private final String eventUrl;

        public SSEObservableHot(String eventUrl) {
            this.eventUrl = eventUrl;
        }

        @Override
        public void call(Subscriber<? super String> subscriber) {
            subscribers.add(subscriber);

            if (subscribers.size() == 1) {
                new Thread(() -> {
                    try {
                        Response response = client.newCall(new Request.Builder()
                                .url(eventUrl)
                                .addHeader("Accept", "text/event-stream")
                                .build())
                                .execute();

                        if (!response.isSuccessful()) {
                            for (Subscriber<? super String> sub: subscribers) {
                                sub.onError(new IOException("Unable to connect to stream"));
                            }
                            return;
                        }

                        InputStream inputStream = response.body().byteStream();
                        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));

                        String line;
                        while ((line = bufferedReader.readLine()) != null) {
                            for (Subscriber<? super String> sub : subscribers) {
                                sub.onNext(line);
                            }
                        }
                    } catch (IOException e) {
                        for (Subscriber<? super String> sub: subscribers) {
                            sub.onError(e);
                        }
                    }
                }).start();
            }
        }
    }

I know there are a few issues with this implementation (no protection on thread death, huge method) - I am just trying to learn how to make a hot observable with rxjava from an SSE stream.