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);