File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
jsdom/src/main/scala/colibri/jsdom Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -4,6 +4,8 @@ import colibri._
4
4
import org .scalajs .dom
5
5
6
6
object EventSourceObservable {
7
+ case class Failed (event : dom.Event ) extends Exception (" Failed EventSource" )
8
+
7
9
def apply (url : String ): Observable [dom.MessageEvent ] =
8
10
from(() => new dom.EventSource (url))
9
11
@@ -13,7 +15,7 @@ object EventSourceObservable {
13
15
def from (createSource : () => dom.EventSource ): Observable [dom.MessageEvent ] = Observable .create { observer =>
14
16
val source = createSource()
15
17
source.onerror = { ev =>
16
- observer.unsafeOnError(new Exception ( s " Failed EventSource ( ${ev.filename} : ${ev.lineno} : ${ev.colno} ): ${ev.message} " ))
18
+ observer.unsafeOnError(Failed (ev ))
17
19
}
18
20
source.onmessage = { ev =>
19
21
observer.unsafeOnNext(ev)
You can’t perform that action at this time.
0 commit comments