TCP Networked Tasklets in Python

Fibra 3 introduces some networking features.

Generator based tasklets can now communicate with each other over TCP! The networking plugin uses Twisted to do its magic. What other sorts of plugins might be useful? I'm running out of ideas now. :-)

This is the code for a simple server which echoes everything it receives, and starts the conversation with a 'hi.' message:

import fibra
import fibra.plugins.sleep
import fibra.plugins.tasks as tasks
import fibra.plugins.network as network


def listener():
    conn = (yield network.ListenForNewConnection(1980))
    conn.send_string('hi.')
    yield echo(conn)
    yield watch(conn)

def watch(connection):
    yield network.WaitForLostConnection(connection)
    print connection, ' has been lost'

def echo(connection):
    while True:
        data = (yield network.WaitForData(connection))
        connection.send_string(data)

s = fibra.Schedule()
s.register_plugin(tasks.TaskPlugin())
s.register_plugin(network.NetworkPlugin())

s.install(listener())

while s.tick(): pass

This is the code for a simple client which echoes everything it receives:

import fibra
import fibra.plugins.sleep
import fibra.plugins.tasks as tasks
import fibra.plugins.network as network


def watch(connection):
    yield network.WaitForLostConnection(connection)
    print connection, ' has been lost'

def echo(connection):
    while True:
        data = (yield network.WaitForData(connection))
        connection.send_string(data)

def connector():
    conn = (yield network.ConnectToHost(('localhost',1980)))
    yield echo(conn)
    yield watch(conn)

s = fibra.Schedule()
s.register_plugin(tasks.TaskPlugin())
s.register_plugin(network.NetworkPlugin())

s.install(connector())

while s.tick(): pass