Module: CZTop::PolymorphicZsockMethods

Included in:
Actor, Socket
Defined in:
lib/cztop/polymorphic_zsock_methods.rb

Overview

These are methods that can be used on a Socket as well as an Actor.

See Also:

Instance Method Summary collapse

Instance Method Details

#set_unbounded ⇒ Object

Set socket to use unbounded pipes (HWM=0); use this in cases when you are totally certain the message volume can fit in memory.



27
28
29
 
# File 'lib/cztop/polymorphic_zsock_methods.rb', line 27

def set_unbounded
  ::CZMQ::FFI::Zsock.set_unbounded(ffi_delegate)
end

#signal(status = 0) ⇒ Object

Sends a signal.

Parameters:

  • status (Integer) (defaults to: 0) —

    signal (0-255)



10
11
12
 
# File 'lib/cztop/polymorphic_zsock_methods.rb', line 10

def signal(status = 0)
  ::CZMQ::FFI::Zsock.signal(ffi_delegate, status)
end

#wait ⇒ Integer

Note:

This will block and is therefore not compatible with Fiber.scheduler (e.g. Async).

Waits for a signal.

Returns:

  • (Integer) —

    the received signal



18
19
20
21
22
 
# File 'lib/cztop/polymorphic_zsock_methods.rb', line 18

def wait
  fail NotImplementedError if !Fiber.blocking?

  ::CZMQ::FFI::Zsock.wait(ffi_delegate)
end