@@ -451,46 +451,46 @@ class multipart_t
451
451
bool empty () const { return m_parts.empty (); }
452
452
453
453
// Receive multipart message from socket
454
- bool recv (socket_ref socket, int flags = 0 )
454
+ bool recv (socket_ref socket, recv_flags flags = recv_flags::none )
455
455
{
456
456
clear ();
457
457
bool more = true ;
458
458
while (more) {
459
459
message_t message;
460
- #ifdef ZMQ_CPP11
461
- if (!socket.recv (message, static_cast <recv_flags>(flags)))
462
- return false ;
463
- #else
464
460
if (!socket.recv (&message, flags))
465
461
return false ;
466
- #endif
467
462
more = message.more ();
468
463
add (std::move (message));
469
464
}
470
465
return true ;
471
466
}
472
467
468
+ // Receive multipart message from socket (old)
469
+ bool recv (socket_ref socket, int flags = 0 ) {
470
+ return recv (socket, static_cast <recv_flags>(flags));
471
+ }
472
+
473
473
// Send multipart message to socket
474
- bool send (socket_ref socket, int flags = 0 )
474
+ bool send (socket_ref socket, send_flags flags = send_flags::none )
475
475
{
476
476
flags &= ~(ZMQ_SNDMORE);
477
477
bool more = size () > 0 ;
478
478
while (more) {
479
479
message_t message = pop ();
480
480
more = size () > 0 ;
481
- #ifdef ZMQ_CPP11
482
- if (!socket.send (message, static_cast <send_flags>(
483
- (more ? ZMQ_SNDMORE : 0 ) | flags)))
484
- return false ;
485
- #else
486
481
if (!socket.send (message, (more ? ZMQ_SNDMORE : 0 ) | flags))
487
482
return false ;
488
- #endif
489
483
}
490
484
clear ();
491
485
return true ;
492
486
}
493
487
488
+ // Send multipart message to socket (old)
489
+ bool send (socket_ref socket, int flags = 0 )
490
+ {
491
+ return send (socket, static_cast <send_flags>(flags));
492
+ }
493
+
494
494
// Concatenate other multipart to front
495
495
void prepend (multipart_t &&other)
496
496
{
0 commit comments