diff --git a/docs/topics/consumers.rst b/docs/topics/consumers.rst
index 0d01f1bb5..4ab17435a 100644
--- a/docs/topics/consumers.rst
+++ b/docs/topics/consumers.rst
@@ -328,7 +328,7 @@ primitives to implement a HTTP endpoint::
         async def handle(self, body):
             await asyncio.sleep(10)
             await self.send_response(200, b"Your response bytes", headers=[
-                ("Content-Type", "text/plain"),
+                (b"Content-Type", b"text/plain"),
             ])
 
 You are expected to implement your own ``handle`` method. The
@@ -352,7 +352,7 @@ be explained in detail later::
     class LongPollConsumer(AsyncHttpConsumer):
         async def handle(self, body):
             await self.send_headers(headers=[
-                ("Content-Type", "application/json"),
+                (b"Content-Type", b"application/json"),
             ])
             # Headers are only sent after the first body event.
             # Set "more_body" to tell the interface server to not
@@ -372,9 +372,9 @@ Of course you can also use those primitives to implement a HTTP endpoint for
     class ServerSentEventsConsumer(AsyncHttpConsumer):
         async def handle(self, body):
             await self.send_headers(headers=[
-                ("Cache-Control", "no-cache"),
-                ("Content-Type", "text/event-stream"),
-                ("Transfer-Encoding", "chunked"),
+                (b"Cache-Control", b"no-cache"),
+                (b"Content-Type", b"text/event-stream"),
+                (b"Transfer-Encoding", b"chunked"),
             ])
             while True:
                 payload = "data: %s\n\n" % datetime.now().isoformat()
diff --git a/tests/test_generic_http.py b/tests/test_generic_http.py
index 4d8b8df75..9150eed4a 100644
--- a/tests/test_generic_http.py
+++ b/tests/test_generic_http.py
@@ -18,7 +18,7 @@ async def handle(self, body):
             await self.send_response(
                 200,
                 json.dumps({"value": data["value"]}).encode("utf-8"),
-                headers={"Content-Type": "application/json"},
+                headers={b"Content-Type": b"application/json"},
             )
 
     # Open a connection
@@ -31,4 +31,4 @@ async def handle(self, body):
     response = await communicator.get_response()
     assert response["body"] == b'{"value": 42}'
     assert response["status"] == 200
-    assert response["headers"] == [("Content-Type", "application/json")]
+    assert response["headers"] == [(b"Content-Type", b"application/json")]