| 11851 | } |
| 11852 | |
| 11853 | function SenderReceiver(transUrl, urlSuffix, senderFunc, Receiver, AjaxObject) { |
| 11854 | var pollUrl = urlUtils.addPath(transUrl, urlSuffix); |
| 11855 | debug(pollUrl); |
| 11856 | var self = this; |
| 11857 | BufferedSender.call(this, transUrl, senderFunc); |
| 11858 | |
| 11859 | this.poll = new Polling(Receiver, pollUrl, AjaxObject); |
| 11860 | this.poll.on('message', function(msg) { |
| 11861 | debug('poll message', msg); |
| 11862 | self.emit('message', msg); |
| 11863 | }); |
| 11864 | this.poll.once('close', function(code, reason) { |
| 11865 | debug('poll close', code, reason); |
| 11866 | self.poll = null; |
| 11867 | self.emit('close', code, reason); |
| 11868 | self.close(); |
| 11869 | }); |
| 11870 | } |
| 11871 | |
| 11872 | inherits(SenderReceiver, BufferedSender); |
| 11873 | |