import urllib.request

from collection_pipelines.core import CollectionPipelineProcessor


def http_get(url):
    return urllib.request.urlopen(url).read()


class http(CollectionPipelineProcessor):
    def __init__(self, url):
        self._set_url(url)
        self.source(self.make_generator)

    def make_generator(self):
        self.receiver.send(http_get(self.url))

    def _set_url(self, url):
        if not url.startswith('http://'):
            url = 'http://' + url

        self.url = url

@@ -99,24 +99,81 @@
 p_get(url):%0A
+    %22%22%22%0A    Returns:%0A        str: response body.%0A    %22%22%22%0A
     return u
@@ -205,16 +205,32 @@
 ).read()
+.decode('utf-8')
 %0A%0A%0Aclass

Update http GET function to return string rather than bytes