diff --git a/lib/pod/infrastructure/feed_parser.rb b/lib/pod/infrastructure/feed_parser.rb
index cbebcb2..d48de10 100644
--- a/lib/pod/infrastructure/feed_parser.rb
+++ b/lib/pod/infrastructure/feed_parser.rb
@@ -4,57 +4,25 @@
 require "feedjira"
 
 require_relative "dto"
-require_relative "function_pipeline"
 
 module Infrastructure
   module FeedParser
     def self.call(feed)
-      pipeline = FunctionPipeline.new(
-        functions: [
-          FetchContent,
-          ParseContent,
-          InitializePodcastDTO,
-          InitializeEpisodesDTO,
-          InitializeFeedDTO
-        ],
-        on_error: InitializeEmptyFeedDTO,
-        context: {feed: feed}
-      )
-
-      pipeline.call
-    end
-
-    private
-
-    FetchContent = ->(ctx) do
-      feed = ctx[:feed]
-
       content = if File.exist?(feed)
         File.new(feed).read
       else
         Net::HTTP.get(URI(feed))
       end
+      parsed_content = Feedjira.parse(content)
 
-      ctx[:content] = content
-    end
-
-    ParseContent = ->(ctx) do
-      ctx[:parsed_content] = Feedjira.parse(ctx[:content])
-    end
-
-    InitializePodcastDTO = ->(ctx) do
-      parsed_content = ctx[:parsed_content]
-      ctx[:podcast] = Infrastructure::DTO.new(
+      podcast = Infrastructure::DTO.new(
         name: parsed_content.title,
         description: parsed_content.description,
         feed: parsed_content.itunes_new_feed_url,
         website: parsed_content.url
       )
-    end
 
-    InitializeEpisodesDTO = ->(ctx) do
-      parsed_content = ctx[:parsed_content]
-      ctx[:episodes] = parsed_content.entries.map do |e|
+      episodes = parsed_content.entries.map do |e|
         Infrastructure::DTO.new(
           title: e.title,
           release_date: e.published.iso8601,
@@ -63,17 +31,11 @@ def self.call(feed)
           external_id: e.entry_id
         )
       end
-    end
 
-    InitializeFeedDTO = ->(ctx) do
-      podcast = ctx[:podcast]
-      episodes = ctx[:episodes]
       # The #reverse is necessary to put the oldest episodes on the top of the feed.
-      ctx[:feed] = Infrastructure::DTO.new(podcast: podcast, episodes: episodes.reverse)
-    end
-
-    InitializeEmptyFeedDTO = ->(ctx) do
-      ctx[:feed] = Infrastructure::DTO.new(podcast: nil, episodes: nil)
+      Infrastructure::DTO.new(podcast: podcast, episodes: episodes.reverse)
+    rescue NoMethodError
+      Infrastructure::DTO.new(podcast: nil, episodes: nil)
     end
   end
 end
diff --git a/lib/pod/infrastructure/function_pipeline.rb b/lib/pod/infrastructure/function_pipeline.rb
deleted file mode 100644
index 5a30cfb..0000000
--- a/lib/pod/infrastructure/function_pipeline.rb
+++ /dev/null
@@ -1,42 +0,0 @@
-# frozen_string_literal: true
-
-module Infrastructure
-  class FunctionPipeline
-    def initialize(functions:, on_error:, context: {})
-      @functions = functions
-      @on_error = on_error
-      @context = Context.new(context)
-    end
-
-    def call
-      @functions.each { |f| f.call(@context) }
-    rescue => e
-      @context[:error] = e
-      @on_error.call(@context)
-    ensure
-      return @context.last_entry # standard:disable Lint/EnsureReturn
-    end
-
-    private
-
-    class Context
-      def initialize(context)
-        @state = context
-      end
-
-      def [](key)
-        @state[key.to_sym]
-      end
-
-      def []=(key, value)
-        @state[key.to_sym] = value
-        @state[:last_entry] = key
-      end
-
-      def last_entry
-        key = @state[:last_entry]
-        @state[key]
-      end
-    end
-  end
-end