class Async::Container::Notify::Socket
def send(**message)
Send the given message.
def send(**message) data = dump(message) if data.bytesize > MAXIMUM_MESSAGE_SIZE raise ArgumentError, "Message length #{data.bytesize} exceeds #{MAXIMUM_MESSAGE_SIZE}: #{message.inspect}" end @address.connect do |peer| peer.sendmsg(data) end end