aionotify/base.py
def setup(self, loop):
        """Start the watcher, registering new watches if any."""
        self._loop = loop

        self._fd = LibC.inotify_init()
        for alias, (path, flags) in self.requests.items():
            self._setup_watch(alias, path, flags)

        # We pass ownership of the fd to the transport; it will close it.
        self._stream, self._transport = yield from aioutils.stream_from_fd(self._fd, loop)
def setup(self, loop):
        """Start the watcher, registering new watches if any."""
        self._loop = loop

        self._fd = LibC.inotify_init()
        for alias, (path, flags) in self.requests.items():
            self._setup_watch(alias, path, flags)

        # We pass ownership of the fd to the transport; it will close it.
        self._stream, self._transport = yield from aioutils.stream_from_fd(self._fd, loop)
def setup ( self , loop ) : self . _loop = loop self . _fd = LibC . inotify_init ( ) for alias , ( path , flags ) in self . requests . items ( ) : self . _setup_watch ( alias , path , flags ) # We pass ownership of the fd to the transport; it will close it. self . _stream , self . _transport = yield from aioutils . stream_from_fd ( self . _fd , loop )
Start the watcher, registering new watches if any.
Start the watcher registering new watches if any .