(self, socket: zmq.Socket, is_producer: bool)
| 55 | immediate: int = 1 |
| 56 | |
| 57 | def apply(self, socket: zmq.Socket, is_producer: bool): |
| 58 | # Apply socket-level configurations |
| 59 | socket.setsockopt(zmq.LINGER, self.linger) |
| 60 | socket.setsockopt(zmq.IMMEDIATE, self.immediate) |
| 61 | |
| 62 | if is_producer: |
| 63 | socket.setsockopt(zmq.SNDHWM, self.sndhwm) |
| 64 | socket.setsockopt(zmq.SNDBUF, self.sndbuf) |
| 65 | else: |
| 66 | socket.setsockopt(zmq.RCVHWM, self.rcvhwm) |
| 67 | socket.setsockopt(zmq.RCVBUF, self.rcvbuf) |
| 68 | |
| 69 | |
| 70 | @dataclass |