Visual Basic

<br />
Public Sub New(ByVal BufferSize As Int32, ByVal SyncObject As     System.ComponentModel.ISynchronizeInvoke)<br />
    _SyncObject = SyncObject<br />
    _Connected = False<br />
    _BufferSize = BufferSize<br />
End Sub<br />

Private Sub BeginReceive(ByVal ar As IAsyncResult)<br />
            Try<br />
                Dim _Bytes As Byte() = CType(ar.AsyncState, Byte())<br />
                Dim _numBytes As Int32 = _Socket.EndReceive(ar)<br />
<br />
                If _numBytes = 0 Then<br />
                    Dim c As New dlgNoParams(AddressOf Disconnect)<br />
                    _SyncObject.Invoke(c, Nothing)<br />
                Else<br />
                    Dim _Data As String = _Ascii.GetString(_Bytes)<br />
                    Dim args(0) As Object<br />
                    args(0) = _Data<br />
                    Dim d As New dlgReceiveData(AddressOf ReceiveData)<br />
                    _SyncObject.Invoke(d, args)<br />
                    Dim e As New dlgNoParams(AddressOf StartReceive)<br />
                    _SyncObject.Invoke(e, Nothing)<br />
                End If<br />
            Catch ex As Exception<br />
<br />
                Dim myType As Type = ex.GetType<br />
                Console.WriteLine(myType.ToString)<br />
                If Not myType.FullName = "System.Net.Sockets.SocketException" Then<br />
                    Dim f As New dlgErrorEvent(AddressOf ErrorEvent)<br />
                    Dim args(0) As Object<br />
                    args(0) = ex<br />
                    _SyncObject.Invoke(f, args)<br />
                Else<br />
                    '_QueueThread.Abort()<br />
                    _Socket = Nothing<br />
                End If<br />
            End Try<br />
        End Sub