'---------------------------------------------------------StreamingProxy-------
' ---------------------------
Imports System.Net
Imports System.Net.Sockets
Namespace StreamingProxy
    Public Class clsStreamingProxy
        Dim server As TcpListener
        Dim buffer As New clsFIFOStack(Of Byte)
        Dim accepter As New List(Of clsStreamingConnectionAccepter)
        Dim t As Threading.Thread
        Dim p As Integer
        Public Sub New(Optional ByVal port As Integer = 16800)
            p = port
        End Sub
        Public Sub StopServer()
            server.Stop()
            For Each a As clsStreamingConnectionAccepter In accepter
                a.Disconnect()
            Next
 
        End Sub
        Public Sub StartServer(Optional ByVal port As Integer = 16800)
            Dim h As System.Net.IPHostEntry = System.Net.Dns.GetHostEntry( _
              System.Net.Dns.GetHostName)
            server = Nothing
            Dim localAddr As IPAddress = IPAddress.Parse("127.0.0.1")
            Dim ipe As New IPEndPoint(h.AddressList(0), port)
            Try
 
                server = New TcpListener(ipe)
                ' Start listening for client requests.
                server.Start()
            Catch e As SocketException
                Console.WriteLine("SocketException: {0}", e)
                Exit Sub
            End Try
            Debug.Print("Server started!")
            t = New Threading.Thread(AddressOf ListenThread)
            t.Start()
        End Sub
 
        Public Sub ListenThread()
            Dim data As String = Nothing
            Dim client As TcpClient
            ' Enter the listening loop.
            Try
                While True
                    Console.Write("Waiting for a connection... ")
 
                    ' Perform a blocking call to accept requests.
                    ' You could also user server.AcceptSocket() here.
                    client = server.AcceptTcpClient()
                    accepter.Add(New clsStreamingConnectionAccepter)
                    accepter(accepter.Count - 1).AcceptRequest(client)
                    'accepter(accepter.Count - 1).PushDataOnBuffer(buffer.Peek( 
                    ' ))
                    WriteToDebug("Ein Client hat sich Verbunden!", _
                      enDebugLevel.dlNote, False)
 
                End While
            Catch e As SocketException
                Console.WriteLine("SocketException: {0}", e)
            Finally
                StopServer()
            End Try
 
            Console.WriteLine(ControlChars.Cr + "Hit enter to continue....")
            Console.Read()
 
        End Sub
        Sub PushData(ByVal b() As Byte, Optional ByVal startindex As Integer = _
          0, Optional ByVal length As Integer = 0)
            buffer.Push(b, startindex, length)
            For Each a As clsStreamingConnectionAccepter In accepter
                a.PushDataOnBuffer(b)
            Next
        End Sub
    End Class
End Namespace
'---------------------------------------------Ende Streaming 
' Proxy-------------------------------