This repository was archived by the owner on Feb 14, 2024. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +22
-22
lines changed Expand file tree Collapse file tree 1 file changed +22
-22
lines changed Original file line number Diff line number Diff line change 10
10
11
11
(def ^:const bytes-type (class (byte-array 0 )))
12
12
13
- (def ^:const no-block ( ZMQ/NOBLOCK ) )
13
+ (def ^:const no-block ZMQ /NOBLOCK )
14
14
15
- (def ^:const dont-wait ( ZMQ/DONTWAIT ) )
15
+ (def ^:const dont-wait ZMQ /DONTWAIT )
16
16
17
- (def ^:const send-more ( ZMQ/SNDMORE ) )
17
+ (def ^:const send-more ZMQ /SNDMORE )
18
18
19
19
(def ^:const socket-options
20
- {:no-block ( ZMQ/NOBLOCK )
21
- :dont-wait ( ZMQ/DONTWAIT )
22
- :send-more ( ZMQ/SNDMORE ) })
20
+ {:no-block ZMQ/NOBLOCK
21
+ :dont-wait ZMQ/DONTWAIT
22
+ :send-more ZMQ/SNDMORE})
23
23
24
24
(def ^:const socket-types
25
- {:pair ( ZMQ/PAIR )
26
- :pub ( ZMQ/PUB )
27
- :sub ( ZMQ/SUB )
28
- :req ( ZMQ/REQ )
29
- :rep ( ZMQ/REP )
30
- :xreq ( ZMQ/XREQ )
31
- :xrep ( ZMQ/XREP )
32
- :dealer ( ZMQ/DEALER )
33
- :router ( ZMQ/ROUTER )
34
- :xpub ( ZMQ/XPUB )
35
- :xsub ( ZMQ/XSUB )
36
- :pull ( ZMQ/PULL )
37
- :push ( ZMQ/PUSH ) })
25
+ {:pair ZMQ/PAIR
26
+ :pub ZMQ/PUB
27
+ :sub ZMQ/SUB
28
+ :req ZMQ/REQ
29
+ :rep ZMQ/REP
30
+ :xreq ZMQ/XREQ
31
+ :xrep ZMQ/XREP
32
+ :dealer ZMQ/DEALER
33
+ :router ZMQ/ROUTER
34
+ :xpub ZMQ/XPUB
35
+ :xsub ZMQ/XSUB
36
+ :pull ZMQ/PULL
37
+ :push ZMQ/PUSH})
38
38
39
39
(def ^:const poller-types
40
- {:pollin ( ZMQ$Poller/POLLIN )
41
- :pollout ( ZMQ$Poller/POLLOUT )
42
- :pollerr ( ZMQ$Poller/POLLERR ) })
40
+ {:pollin ZMQ$Poller/POLLIN
41
+ :pollout ZMQ$Poller/POLLOUT
42
+ :pollerr ZMQ$Poller/POLLERR})
43
43
44
44
(defn first-free-port
45
45
" Returns first free ephemeral port"
You can’t perform that action at this time.
0 commit comments