RxRuby - Simple HTTP Server

Gemfile

# frozen_string_literal: true
# A sample Gemfile
source "https://rubygems.org"

gem "rx"

http.rb

# Load Ruby Gems
require 'rubygems'
require 'bundler'

Bundler.require

server = TCPServer.new('0.0.0.0', 8080)

rx_request = Rx::Subject.new

PATH_RULE = /^GET\s+(?<path>[^\s]+).+?/

events = rx_request.as_observable.map do |request, response|
  matches = PATH_RULE.match(request)
  [matches[:path], response]
end
events.subscribe do |path, response|
  msg = "Hi, you try to get #{path}"

  response.print [
    "HTTP/1.1 200 OK",
    "Content-Type: text/plain",
    "Content-Length: #{msg.bytesize}",
    "Connection: close",
    "",
    msg
  ].join("\r\n")

end

loop do

  socket = server.accept

  request = socket.gets

  rx_request.on_next [request, socket]

  socket.close
end