def test_channel_close_and_then_receive_error_multiple(self):

->     channel = self.gw.remote_exec('channel.send(42) ; raise ValueError')

       x = channel.receive()

       assert x == 42

       py.test.raises(channel.RemoteError, channel.receive)

   def remote_exec(self, source, stdout=None, stderr=None): 

       """ return channel object and connect it to a remote

               execution thread where the given 'source' executes

               and has the sister 'channel' object in its global 

               namespace.  The callback functions 'stdout' and 

               'stderr' get called on receival of remote 

               stdout/stderr output strings. 

           """

       try:

           source = str(Source(source))

       except NameError: 

           try: 

               import py 

               source = str(py.code.Source(source))

           except ImportError: 

               pass 

->     channel = self.newchannel() 

       outid = self._newredirectchannelid(stdout) 

       errid = self._newredirectchannelid(stderr) 

       self._send(Message.CHANNEL_OPEN(

                   channel.id, (source, outid, errid)))

       return channel 

   def newchannel(self): 

       """ return new channel object.  """ 

->     return self._channelfactory.new()

   def new(self, id=None):

       """ create a new Channel with 'id' (or create new id if None). """

       self._writelock.acquire()

       try:

           if self.finished:

               raise IOError("connexion already closed: %s" % (self.gateway,))

           if id is None:

               id = self.count

               self.count += 2

->         channel = Channel(self.gateway, id)

           self._channels[id] = channel

           return channel

       finally:

           self._writelock.release()