← Back to branch summary

~ubuntu-branches/ubuntu/precise/pyzmq/precise

« back to all changes in this revision

Viewing changes to zmq/eventloop/zmqstream.py

  • Committer: Package Import Robot
  • Author(s): Debian Python Modules Team
  • Date: 2011-09-23 00:16:39 UTC
  • mfrom: (1.1.4 upstream)
  • Revision ID: package-import@ubuntu.com-20110923001639-girjqodpb7uv17yu
Tags: 2.1.9-1
http://bugs.debian.org/637777
* New upstream version
  - should build on kFreeBSD without patches (Closes: #637777).
* Build-depend on zeromq 2.1.9

Show diffs side-by-side

added added

removed removed

Lines of Context:
zmq/eventloop/zmqstream.py
145
145
        
146
146
        Returns : None
147
147
        """
148
 
        
 
148
        self._check_closed()
149
149
        assert callback is None or callable(callback)
150
150
        self._recv_callback = stack_context.wrap(callback)
151
151
        self._recv_copy = copy
180
180
            
181
181
            if callback is None, send callbacks are disabled.
182
182
        """
 
183
        self._check_closed()
183
184
        assert callback is None or callable(callback)
184
185
        self._send_callback = stack_context.wrap(callback)
185
186
        
193
194
        callback : callable
194
195
            callback will be passed no arguments.
195
196
        """
 
197
        self._check_closed()
196
198
        assert callback is None or callable(callback)
197
199
        self._errback = stack_context.wrap(callback)
198
200
        
207
209
        """Send a multipart message, optionally also register a new callback for sends.
208
210
        See zmq.socket.send_multipart for details.
209
211
        """
210
 
        # self._check_closed()
211
212
        self._send_queue.put((msg, flags, copy))
212
213
        callback = callback or self._send_callback
213
214
        if callback is not None:
278
279
        -------
279
280
        int : count of events handled (both send and recv)
280
281
        """
 
282
        self._check_closed()
281
283
        # unset self._flushed, so callbacks will execute, in case flush has
282
284
        # already been called this iteration
283
285
        already_flushed = self._flushed