class MemoryReactor: (source)
Known subclasses: twisted.internet.testing.MemoryReactorClock
Implements interfaces: twisted.internet.interfaces.IReactorCore
, twisted.internet.interfaces.IReactorFDSet
, twisted.internet.interfaces.IReactorSocket
, twisted.internet.interfaces.IReactorSSL
, twisted.internet.interfaces.IReactorTCP
, twisted.internet.interfaces.IReactorUNIX
A fake reactor to be used in tests. This reactor doesn't actually do much that's useful yet. It accepts TCP connection setup attempts, but they will never succeed.
Instance Variable | hasInstalled |
Keeps track of whether this reactor has been installed. |
Instance Variable | running |
Keeps track of whether this reactor is running. |
Instance Variable | hasStopped |
Keeps track of whether this reactor has been stopped. |
Instance Variable | hasCrashed |
Keeps track of whether this reactor has crashed. |
Instance Variable | whenRunningHooks |
Keeps track of hooks registered with callWhenRunning . |
Instance Variable | triggers |
Keeps track of hooks registered with addSystemEventTrigger . |
Instance Variable | tcpClients |
Keeps track of connection attempts (ie, calls to connectTCP ). |
Instance Variable | tcpServers |
Keeps track of server listen attempts (ie, calls to listenTCP ). |
Instance Variable | sslClients |
Keeps track of connection attempts (ie, calls to connectSSL ). |
Instance Variable | sslServers |
Keeps track of server listen attempts (ie, calls to listenSSL ). |
Instance Variable | unixClients |
Keeps track of connection attempts (ie, calls to connectUNIX ). |
Instance Variable | unixServers |
Keeps track of server listen attempts (ie, calls to listenUNIX ). |
Instance Variable | adoptedPorts |
Keeps track of server listen attempts (ie, calls to adoptStreamPort ). |
Instance Variable | adoptedStreamConnections |
Keeps track of stream-oriented connections added using adoptStreamConnection . |
Method | __init__ |
Initialize the tracking lists. |
Instance Variable | hasRun |
Undocumented |
Instance Variable | connectors |
Undocumented |
Instance Variable | readers |
Undocumented |
Instance Variable | writers |
Undocumented |
Method | install |
Fake install callable to emulate reactor module installation. |
Method | resolve |
Not implemented; raises NotImplementedError . |
Method | run |
No summary |
Method | stop |
Fake IReactorCore.run . Sets self.running to False . Sets self.hasStopped to True . |
Method | crash |
Fake IReactorCore.crash . Sets self.running to None , because that feels crashy. Sets self.hasCrashed to True . |
Method | iterate |
Not implemented; raises NotImplementedError . |
Method | fireSystemEvent |
Not implemented; raises NotImplementedError . |
Method | addSystemEventTrigger |
Fake IReactorCore.run . Keep track of trigger by appending it to self.triggers[phase][eventType]. |
Method | removeSystemEventTrigger |
Not implemented; raises NotImplementedError . |
Method | callWhenRunning |
Fake IReactorCore.callWhenRunning . Keeps a list of invocations to make in self.whenRunningHooks . |
Method | adoptStreamPort |
Fake IReactorSocket.adoptStreamPort , that logs the call and returns an IListeningPort . |
Method | adoptStreamConnection |
Record the given stream connection in adoptedStreamConnections . |
Method | adoptDatagramPort |
Fake IReactorSocket.adoptDatagramPort , that logs the call and returns a fake IListeningPort . |
Method | listenTCP |
Fake IReactorTCP.listenTCP , that logs the call and returns an IListeningPort . |
Method | connectTCP |
Fake IReactorTCP.connectTCP , that logs the call and returns an IConnector . |
Method | listenSSL |
Fake IReactorSSL.listenSSL , that logs the call and returns an IListeningPort . |
Method | connectSSL |
Fake IReactorSSL.connectSSL , that logs the call and returns an IConnector . |
Method | listenUNIX |
Fake IReactorUNIX.listenUNIX , that logs the call and returns an IListeningPort . |
Method | connectUNIX |
Fake IReactorUNIX.connectUNIX , that logs the call and returns an IConnector . |
Method | addReader |
Fake IReactorFDSet.addReader which adds the reader to a local set. |
Method | removeReader |
Fake IReactorFDSet.removeReader which removes the reader from a local set. |
Method | addWriter |
Fake IReactorFDSet.addWriter which adds the writer to a local set. |
Method | removeWriter |
Fake IReactorFDSet.removeWriter which removes the writer from a local set. |
Method | getReaders |
Fake IReactorFDSet.getReaders which returns a list of readers from the local set. |
Method | getWriters |
Fake IReactorFDSet.getWriters which returns a list of writers from the local set. |
Method | removeAll |
Fake IReactorFDSet.removeAll which removed all readers and writers from the local sets. |
listenUNIX
).list
)
adoptStreamPort
).list
)
adoptStreamConnection
.list
)
Fake IReactorCore.run
. Sets self.running
to True
, runs all of the hooks passed to self.callWhenRunning
, then calls self.stop
to simulate a request to stop the reactor. Sets self.hasRun
to True
.
Fake IReactorCore.crash
. Sets self.running
to None
, because that feels crashy. Sets self.hasCrashed
to True
.
Fake IReactorCore.run
. Keep track of trigger by appending it to self.triggers[phase][eventType].
Parameters | phase | Undocumented (type: str ) |
eventType | Undocumented (type: str ) | |
callable | Undocumented (type: Callable[..., Any] ) | |
args | Undocumented | |
kw | Undocumented |
Fake IReactorCore.callWhenRunning
. Keeps a list of invocations to make in self.whenRunningHooks
.
Parameters | callable | Undocumented (type: Callable[..., Any] ) |
args | Undocumented | |
kw | Undocumented |
Record the given stream connection in adoptedStreamConnections
.
See Also | twisted.internet.interfaces.IReactorSocket.adoptStreamConnection |
Fake IReactorSocket.adoptDatagramPort
, that logs the call and returns a fake IListeningPort
.
See Also | twisted.internet.interfaces.IReactorSocket.adoptDatagramPort |