From 2ec859f1021d0948b81c83700b0cee39342b5204 Mon Sep 17 00:00:00 2001
From: Adi Roiban
-from twisted.internet import protocol, reactor, endpoints
+import math
+
+from twisted.internet import protocol, endpoints, task
class Echo(protocol.Protocol):
def dataReceived(self, data):
@@ -190,8 +192,16 @@
def buildProtocol(self, addr):
return Echo()
-endpoints.serverFromString(reactor, "tcp:1234").listen(EchoFactory())
-reactor.run()
+async def echo_server(reactor):
+ await endpoints.serverFromString(reactor, "tcp:1234").listen(EchoFactory())
+ await task.deferLater(reactor, math.inf, lambda: pass)
+ return 0
+
+def main():
+ return task.react(echo_server)
+
+if __name__ == "__main__":
+ sys.exit(main())
From 5a09c1b8aa7e21a98d4f9211434179bc49338721 Mon Sep 17 00:00:00 2001
From: Thomas Grainger
async def echo_server(reactor):
await endpoints.serverFromString(reactor, "tcp:1234").listen(EchoFactory())
- await task.deferLater(reactor, math.inf, lambda: pass)
+ await task.deferLater(reactor, math.inf)
return 0
def main():
From 967d7dcb44b28faf8c2bdfb21c63a94c687b67b8 Mon Sep 17 00:00:00 2001
From: Thomas Grainger
import math
+import sys
+
+from twisted.internet import endpoints, protocol, task
-from twisted.internet import protocol, endpoints, task
class Echo(protocol.Protocol):
def dataReceived(self, data):
self.transport.write(data)
+
class EchoFactory(protocol.Factory):
def buildProtocol(self, addr):
return Echo()
+
async def echo_server(reactor):
await endpoints.serverFromString(reactor, "tcp:1234").listen(EchoFactory())
await task.deferLater(reactor, math.inf)
return 0
+
def main():
return task.react(echo_server)
+
if __name__ == "__main__":
sys.exit(main())