old_contents: import clr
  clr.AddReference("Emcaster")
  clr.AddReference("EmcasterTest")
  
  from EmcasterTest import *
  from Emcaster.Sockets import *
  from Emcaster.Topics import *
  from System.Threading import *
  
  import sys
  
  Startup.Init();
  
  address = "224.0.0.23"
  port = 8001
  
  sendSocket = PgmSource(address, port)
  sendSocket.RateKbitsPerSec = 75000
  sendSocket.WindowSizeInMSecs = 2000
  sendSocket.WindowSizeinBytes = 0
  
  sys.exitfunc = sendSocket.Dispose
  
  asyncWriter = AsyncByteWriter(sendSocket, 1024*128)
  asyncWriter.PrintStats = 1
  
  publisher = TopicPublisher(asyncWriter);
  
  topic = "test"
  bytes = 10
  waitTime = 1000
  msgCount = 9999999
  
  def send_all():
  	Startup.PublishBatch(publisher, topic, bytes, waitTime, msgCount)
  
  def go():
  	sendSocket.Start()
  	publisher.Start()
  	send_all()
  	
  print "Ready to Publish: ", address, " " , port
new_contents: import clr
  clr.AddReference("Emcaster")
  clr.AddReference("EmcasterTest")
  
  from EmcasterTest import *
  from Emcaster.Sockets import *
  from Emcaster.Topics import *
  from System.Threading import *
  
  import sys
  
  Startup.Init();
  
  address = "224.0.0.23"
  port = 8001
  
  sendSocket = PgmSource(address, port)
  sendSocket.RateKbitsPerSec = 100000
  sendSocket.WindowSizeInMSecs = 2000
  sendSocket.WindowSizeinBytes = 0
  
  sys.exitfunc = sendSocket.Dispose
  
  asyncWriter = AsyncByteWriter(sendSocket, 1024*128)
  asyncWriter.PrintStats = 1
  
  publisher = TopicPublisher(asyncWriter);
  
  topic = "test"
  bytes = 10
  waitTime = 1000
  msgCount = 9999999
  
  def send_all():
  	Startup.PublishBatch(publisher, topic, bytes, waitTime, msgCount)
  
  def go():
  	sendSocket.Start()
  	publisher.Start()
  	send_all()
  	
  print "Ready to Publish: ", address, " " , port
subject: set to 100 megabit.