Initial implementation

[lovelydinosaur]

A very basic initial implementation to get all the sync/async and type checking etc up and going.

Creates an HTTP/1.1 connection on every request.

Sync:

importhttpcoredefmain():
withhttpcore.SyncConnectionPool() ashttp:
http_version, status_code, reason_phrase, headers, stream=http.request(
method=b'GET',
url=(b'https', b'example.org', 443, b'/'),
headers=[(b'host', b'example.org')]
)
try:
body=b''forchunkinstream:
body+=chunkfinally:
stream.close()
print(b"%s %d %s"% (http_version, status_code, reason_phrase))
forkey, valueinheaders:
print(b"%s: %s"% (key, value))
print(b"")
print(body)
main()

Async, Trio:

importtrioimporthttpcoreasyncdefmain():
asyncwithhttpcore.AsyncConnectionPool() ashttp:
http_version, status_code, reason_phrase, headers, stream=awaithttp.request(
method=b'GET',
url=(b'https', b'example.org', 443, b'/'),
headers=[(b'host', b'example.org')]
)
try:
body=b''asyncforchunkinstream:
body+=chunkfinally:
awaitstream.close()
print(b"%s %d %s"% (http_version, status_code, reason_phrase))
forkey, valueinheaders:
print(b"%s: %s"% (key, value))
print(b"")
print(body)
trio.run(main)

Async, Asyncio:

importasyncioimporthttpcoreasyncdefmain():
asyncwithhttpcore.AsyncConnectionPool() ashttp:
http_version, status_code, reason_phrase, headers, stream=awaithttp.request(
method=b'GET',
url=(b'https', b'example.org', 443, b'/'),
headers=[(b'host', b'example.org')]
)
try:
body=b''asyncforchunkinstream:
body+=chunkfinally:
awaitstream.close()
print(b"%s %d %s"% (http_version, status_code, reason_phrase))
forkey, valueinheaders:
print(b"%s: %s"% (key, value))
print(b"")
print(body)
asyncio.run(main())