From a3c6b5b4ba86c3987579456f140dac9bc06a5c85 Mon Sep 17 00:00:00 2001 From: Reece Wilson Date: Wed, 28 Dec 2022 12:09:07 +0000 Subject: [PATCH] [*] Updated Aurora Runtime --- README.md | 6 +----- Source/AuRPCPipe.cpp | 8 ++++---- 2 files changed, 5 insertions(+), 9 deletions(-) diff --git a/README.md b/README.md index 8e4636f..5bb86b6 100644 --- a/README.md +++ b/README.md @@ -61,8 +61,4 @@ void Run() gRpcClientChannel->SetCallbacks(callback); } -``` - - - -__Linux IO is lagging behind__ \ No newline at end of file +``` \ No newline at end of file diff --git a/Source/AuRPCPipe.cpp b/Source/AuRPCPipe.cpp index cbd4903..1f066bb 100644 --- a/Source/AuRPCPipe.cpp +++ b/Source/AuRPCPipe.cpp @@ -197,11 +197,11 @@ void AuRPCPipe::OnConnect() RpcLogDebug("RPC Pipe connection initiated. Beginning read..."); AuIO::IOPipeRequestAIO req; - req.asyncTransaction = this->pipe->NewAsyncTransaction(); - req.isStream = true; + req.pAsyncTransaction = this->pipe->NewAsyncTransaction(); + req.bIsStream = true; req.output.type = AuIO::EPipeCallbackType::eTryHandleBufferedPart; - req.output.handleBufferedStream.onData = AuSPtr(this->channel->ToContext(), this); - req.listener = AuSPtr(this->channel->ToContext(), this); + req.output.handleBufferedStream.pOnData = AuSPtr(this->channel->ToContext(), this); + req.pListener = AuSPtr(this->channel->ToContext(), this); // Create a pipe to process an asynchronous repeating stream read transaction of no particular read/EoS limit this->work = GetRPCProcessor()->ToPipeProcessor()->NewAIOPipe(req);