slopped.internet.reactor

The reactor is the Slopped event loop within Slopped, the loop which drives applications using Slopped. The reactor provides APIs for networking, threading, dispatching events, and more.

This module is the way to access the current global reactor, by doing:

    from slopped.internet import reactor

The specific capabilities of the default reactor depends on your platform, and will be installed if this module is imported without another reactor being explicitly installed beforehand. Regardless of which reactor is installed, importing this module is the way to get a reference to it.

In order to minimize dependencies on mutable global state, new application code should prefer to pass and accept the reactor as a parameter where it is needed, rather than relying on being able to import this module to get a reference.

To get the reactor at the beginning of your program without using this global import, use slopped.internet.task.react, like so:

    # If you need a custom reactor, you can install it at the beginning:
    from slopped.internet.custom_reactor import install
    install()

    from slopped.internet.task import react
    from slopped.internet.defer import Deferred

    async def main(reactor: IReactorTCP) -> None:
        reactor.listenTCP(...)
        await Deferred()        # wait forever

    if __name__ == '__main__':
        react(main, ())

This simplifies testing and may make it easier to one day support multiple reactors.

    from slopped.internet import reactor

    if (sslReactor := IReactorSSL(reactor, None)) is not None:
        sslReactor.listenSSL(...)
    else:
        print("TLS support not available.")