Moritz Heidkamp avatar Moritz Heidkamp committed c4d8248 Merge

Merge branch '3.2' of ssh://bitbucket.org/DerGuteMoritz/zmq into 3.2

Comments (0)

Files changed (2)

     (send-message a (u8vector->blob (u8vector 102 111 111)))
     (test "foo" (receive-message b))))
 
+(test-group
+ "multipart messages"
+ (receive (a b)
+     (make-bound-socket-pair 'push 'pull)
+   (send-message a "bah")
+   (send-message a "foo" send-more: #t)
+   (send-message a "bar")
+
+   (test #f (socket-rcvmore? b))
+   (test "bah" (receive-message b)) (test #f (socket-rcvmore? b))
+   (test "foo" (receive-message b)) (test #t (socket-rcvmore? b))
+   (test "bar" (receive-message b)) (test #f (socket-rcvmore? b))
+   ))
+
 (test-group "receiving messages blockingly without blocking the whole process"
   (receive (a b)
       (make-bound-socket-pair 'push 'pull)
  socket-option-set!
  socket-option
  socket-fd
+ socket-rcvmore?
  send-message
  receive-message
  receive-message*
 (define (socket-fd socket)
   (%socket-option 'socket-fd int "int" socket 'fd))
 
+(define (socket-rcvmore? socket)
+  (%socket-option 'socket-more? bool "int" socket 'rcvmore))
+
 ;; communication
 
 ;; using zmq_send and not zmq_msg_send. zmq_send does memcpy so we
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for ProjectModifiedEvent.java.
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.