diff options
| author | Dominik Picheta <dominikpicheta@googlemail.com> | 2017-05-08 15:29:41 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-05-08 15:29:41 +0100 |
| commit | 2edcd07031bdd7555c43b59c0af0836eb469bbb0 (patch) | |
| tree | 28c8cafc0eaf0799b20a14441a433d80e8c1a5d5 | |
| parent | a3e0a7ebbb7682fa40643b1e876ff229e76ba740 (diff) | |
| parent | 2670a6f8a54a40fc92abf34e95d2d3a4010d57b1 (diff) | |
| download | Nim-2edcd07031bdd7555c43b59c0af0836eb469bbb0.tar.gz | |
Merge pull request #5782 from cdunn2001/setGlobalDispatcher
setGlobalDispatcher()
| -rw-r--r-- | lib/pure/asyncdispatch.nim | 10 | ||||
| -rw-r--r-- | lib/upcoming/asyncdispatch.nim | 10 |
2 files changed, 20 insertions, 0 deletions
diff --git a/lib/pure/asyncdispatch.nim b/lib/pure/asyncdispatch.nim index 6a877be30..e48fe8d94 100644 --- a/lib/pure/asyncdispatch.nim +++ b/lib/pure/asyncdispatch.nim @@ -242,6 +242,11 @@ when defined(windows) or defined(nimdoc): if gDisp.isNil: gDisp = newDispatcher() result = gDisp + proc setGlobalDispatcher*(disp: PDispatcher) = + if not gDisp.isNil: + assert gDisp.callbacks.len == 0 + gDisp = disp + proc register*(fd: AsyncFD) = ## Registers ``fd`` with the dispatcher. let p = getGlobalDispatcher() @@ -931,6 +936,11 @@ else: if gDisp.isNil: gDisp = newDispatcher() result = gDisp + proc setGlobalDispatcher*(disp: PDispatcher) = + if not gDisp.isNil: + assert gDisp.callbacks.len == 0 + gDisp = disp + proc update(fd: AsyncFD, events: set[Event]) = let p = getGlobalDispatcher() assert fd.SocketHandle in p.selector diff --git a/lib/upcoming/asyncdispatch.nim b/lib/upcoming/asyncdispatch.nim index 7c0497cc6..8541bf98c 100644 --- a/lib/upcoming/asyncdispatch.nim +++ b/lib/upcoming/asyncdispatch.nim @@ -219,6 +219,11 @@ when defined(windows) or defined(nimdoc): if gDisp.isNil: gDisp = newDispatcher() result = gDisp + proc setGlobalDispatcher*(disp: PDispatcher) = + if not gDisp.isNil: + assert gDisp.callbacks.len == 0 + gDisp = disp + proc register*(fd: AsyncFD) = ## Registers ``fd`` with the dispatcher. let p = getGlobalDispatcher() @@ -1080,6 +1085,11 @@ else: if gDisp.isNil: gDisp = newDispatcher() result = gDisp + proc setGlobalDispatcher*(disp: PDispatcher) = + if not gDisp.isNil: + assert gDisp.callbacks.len == 0 + gDisp = disp + proc register*(fd: AsyncFD) = let p = getGlobalDispatcher() var data = newAsyncData() |