diff --git a/src/shared.jl b/src/shared.jl index 2f9c0a4..3797b2e 100644 --- a/src/shared.jl +++ b/src/shared.jl @@ -38,7 +38,7 @@ function _serialize_msg(io::IO, msg_type::UInt8, msg_id::MsgID, msg_data::Any) try write(io, msg_type) write(io, msg_id) - serialize(io, msg_data) + Base.invokelatest(serialize, io, msg_data) write(io, MSG_BOUNDARY) flush(io) finally diff --git a/src/worker.jl b/src/worker.jl index 82ebe52..936564d 100644 --- a/src/worker.jl +++ b/src/worker.jl @@ -75,7 +75,7 @@ function serve(server::Sockets.TCPServer) msg_id = read(io, MsgID) msg_data, success = try - (deserialize(io), true) + (Base.invokelatest(deserialize, io), true) catch err (format_error(err, catch_backtrace()), false) finally