← Back to branch summary

~ntt-pf-lab/nova/monkey_patch_notification

« back to all changes in this revision

Viewing changes to vendor/Twisted-10.0.0/doc/web/howto/listings/client/response.py

  • Committer: Jesse Andrews
  • Date: 2010-05-28 06:05:26 UTC
  • Revision ID: git-v1:bf6e6e718cdc7488e2da87b21e258ccc065fe499
initial commit

Show diffs side-by-side

added added

removed removed

Lines of Context:
vendor/Twisted-10.0.0/doc/web/howto/listings/client/response.py
 
1
from pprint import pformat
 
2
 
 
3
from twisted.internet import reactor
 
4
from twisted.internet.defer import Deferred
 
5
from twisted.internet.protocol import Protocol
 
6
from twisted.web.client import Agent
 
7
from twisted.web.http_headers import Headers
 
8
 
 
9
class BeginningPrinter(Protocol):
 
10
    def __init__(self, finished):
 
11
        self.finished = finished
 
12
        self.remaining = 1024 * 10
 
13
 
 
14
    def dataReceived(self, bytes):
 
15
        if self.remaining:
 
16
            display = bytes[:self.remaining]
 
17
            print 'Some data received:'
 
18
            print display
 
19
            self.remaining -= len(display)
 
20
 
 
21
    def connectionLost(self, reason):
 
22
        print 'Finished receiving body:', reason.getErrorMessage()
 
23
        self.finished.callback(None)
 
24
 
 
25
agent = Agent(reactor)
 
26
d = agent.request(
 
27
    'GET',
 
28
    'http://example.com/',
 
29
    Headers({'User-Agent': ['Twisted Web Client Example']}),
 
30
    None)
 
31
 
 
32
def cbRequest(response):
 
33
    print 'Response version:', response.version
 
34
    print 'Response code:', response.code
 
35
    print 'Response phrase:', response.phrase
 
36
    print 'Response headers:'
 
37
    print pformat(list(response.headers.getAllRawHeaders()))
 
38
    finished = Deferred()
 
39
    response.deliverBody(BeginningPrinter(finished))
 
40
    return finished
 
41
d.addCallback(cbRequest)
 
42
 
 
43
def cbShutdown(ignored):
 
44
    reactor.stop()
 
45
d.addBoth(cbShutdown)
 
46
 
 
47
reactor.run()