'L{WorkerLogObserver} forwards data to L{managercommands.TestWrite}.'

def test_emit(self):

    calls = []
    class FakeClient(object, ):
        def callRemote(self, method, **kwargs):
            calls.append((method, kwargs))
    observer = WorkerLogObserver(FakeClient())
    observer.emit({'message': ['Some    log']})
    self.assertEqual(calls, [(managercommands.TestWrite, {'out': 'Some    log'})])
