diff --git a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/NamedPipeWorker.cs b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/NamedPipeWorker.cs index 6ea8296..60c5a00 100644 --- a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/NamedPipeWorker.cs +++ b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/NamedPipeWorker.cs @@ -249,9 +249,9 @@ async void RunReceiveLoop(Stream pipeStream, Func x.IsGenericType && x.Name.StartsWith("IAsyncRequestHandler")) - .First(x => x.GetGenericArguments().Any(x => x.FullName == header.RequestType)); + .First(x => x.GetGenericArguments().Any(y => y.FullName == header.RequestType)); var coreInterfaceType = t.GetInterfaces().Where(x => x.IsGenericType && x.Name.StartsWith("IAsyncRequestHandlerCore")) - .First(x => x.GetGenericArguments().Any(x => x.FullName == header.RequestType)); + .First(x => x.GetGenericArguments().Any(y => y.FullName == header.RequestType)); var service = provider.GetRequiredService(interfaceType); // IAsyncRequestHandler var genericArgs = interfaceType.GetGenericArguments(); // [TRequest, TResponse] var request = MessagePackSerializer.Deserialize(genericArgs[0], message.ValueMemory, options.MessagePackSerializerOptions); diff --git a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/TcpWorker.cs b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/TcpWorker.cs index 16d2e75..fbe9939 100644 --- a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/TcpWorker.cs +++ b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe.Interprocess/Runtime/Workers/TcpWorker.cs @@ -264,9 +264,9 @@ async void RunReceiveLoop(SocketTcpClient client) { var t = AsyncRequestHandlerRegistory.Get(reqTypeName, resTypeName); var interfaceType = t.GetInterfaces().Where(x => x.IsGenericType && x.Name.StartsWith("IAsyncRequestHandler")) - .First(x => x.GetGenericArguments().Any(x => x.FullName == header.RequestType)); + .First(x => x.GetGenericArguments().Any(y => y.FullName == header.RequestType)); var coreInterfaceType = t.GetInterfaces().Where(x => x.IsGenericType && x.Name.StartsWith("IAsyncRequestHandlerCore")) - .First(x => x.GetGenericArguments().Any(x => x.FullName == header.RequestType)); + .First(x => x.GetGenericArguments().Any(y => y.FullName == header.RequestType)); var service = provider.GetRequiredService(interfaceType); // IAsyncRequestHandler var genericArgs = interfaceType.GetGenericArguments(); // [TRequest, TResponse] // Unity IL2CPP does not work(can not invoke nongenerics MessagePackSerializer)