lib/dcell/celluloid_ext.rb in dcell-0.7.1 vs lib/dcell/celluloid_ext.rb in dcell-0.8.0
- old
+ new
@@ -52,6 +52,18 @@
# network and back to the original mailbox
def self._load(string)
DCell::MailboxProxy._load(string)
end
end
+
+ class SyncCall
+ def _dump(level)
+ rpc_id = DCell::RPC::Manager.register self
+ payload = Marshal.dump([@caller,@method,@arguments,@block])
+ "#{rpc_id.to_s(16)}@#{DCell.id}:#{payload}"
+ end
+
+ def self._load(string)
+ DCell::RPC._load(string)
+ end
+ end
end