@@ -1527,7 +1527,7 @@ def add(x):
15271527
15281528 # XXX: relocate some of these tests into their own module
15291529 def testNotificationManager (self ):
1530- from ..driver . notifyman import NotificationManager as NM
1530+ from ..notifyman import NotificationManager as NM
15311531 # signals each other
15321532 db = self .db
15331533 alt = self .db .clone ()
@@ -1555,7 +1555,7 @@ def testNotificationManager(self):
15551555 self .fail ("unknown connection received notify.." )
15561556
15571557 def testNotificationManagerTimeout (self ):
1558- from ..driver . notifyman import NotificationManager as NM
1558+ from ..notifyman import NotificationManager as NM
15591559 nm = NM (self .db , timeout = 0.1 )
15601560 self .db .listen ('foo' )
15611561 count = 0
@@ -1578,7 +1578,7 @@ def testNotificationManagerZeroTimeout(self):
15781578 # Zero-timeout means raise StopIteration when
15791579 # there are no notifications to emit.
15801580 # It checks the wire, but does *not* wait for data.
1581- from ..driver . notifyman import NotificationManager as NM
1581+ from ..notifyman import NotificationManager as NM
15821582 nm = NM (self .db , timeout = 0 )
15831583 self .db .listen ('foo' )
15841584 self .failUnlessEqual (list (nm ), [])
@@ -1613,7 +1613,7 @@ def testNotificationManagerZeroTimeout(self):
16131613 # Zero-timeout means raise StopIteration when
16141614 # there are no notifications to emit.
16151615 # It checks the wire, but does *not* wait for data.
1616- from ..driver . notifyman import NotificationManager as NM
1616+ from ..notifyman import NotificationManager as NM
16171617 self .db .listen ('foo' )
16181618 self .failUnlessEqual (list (self .db .wait (0 )), [])
16191619 self .db .notify ('foo' )
0 commit comments