def _call_publish(self, ms_id, args):
        ns = self._nsmgr.get_stream(ms_id)
        if not ns:
            raise CallResultError('invalid stream %r' % (ms_id,))

        d = defer.maybeDeferred(self._app.publish, ns, *args[1:])
        return d
dataset/ETHPy150Open arkadini/twimp/twimp/server/appserver.py/AppDispatchServerProtocol._call_publish/original