ReadCallback()

virtual void Terraria.Social.WeGame.IPCBase.ReadCallback ( IAsyncResult result )

inlinevirtual

Reimplemented in Terraria.Social.WeGame.IPCClient, and Terraria.Social.WeGame.IPCServer.

Definition at line 128 of file IPCBase.cs.

    {
        WeGameHelper.WriteDebugString("ReadCallback: " + Thread.CurrentThread.ManagedThreadId);
        IPCContent iPCContent = (IPCContent)result.AsyncState;
        try
        {
            int num = _pipeStream.EndRead(result);
            if (!iPCContent.CancelToken.IsCancellationRequested)
            {
                if (num > 0)
                {
                    _totalData.AddRange(iPCContent.data.Take(num));
                    if (_pipeStream.IsMessageComplete)
                    {
                        AddPackToList(_totalData);
                        _totalData = new List<byte>();
                    }
                }
            }
            else
            {
                WeGameHelper.WriteDebugString("IPCBase.ReadCallback.cancel");
            }
        }
        catch (IOException ex)
        {
            _pipeBrokenFlag = true;
            WeGameHelper.WriteDebugString("ReadCallback Exception, {0}", ex.Message);
        }
        catch (InvalidOperationException ex2)
        {
            _pipeBrokenFlag = true;
            WeGameHelper.WriteDebugString("ReadCallback Exception, {0}", ex2.Message);
        }
    }

References Terraria.Social.WeGame.IPCBase._pipeBrokenFlag, Terraria.Social.WeGame.IPCBase._pipeStream, Terraria.Social.WeGame.IPCBase._totalData, Terraria.Social.WeGame.IPCBase.AddPackToList(), System.Collections.Generic.List< T >.AddRange(), System.IAsyncResult.AsyncState, System.Threading.Thread.CurrentThread, System.IO.Pipes.PipeStream.EndRead(), System.IO.Pipes.PipeStream.IsMessageComplete, and Terraria.Social.WeGame.WeGameHelper.WriteDebugString().

Referenced by Terraria.Social.WeGame.IPCBase.BeginReadData().