Contents

# frozen_string_literal: true

require 'bundler/setup'
require 'polyphony'

class GenServer
  def self.start(receiver, *args)
    coprocess = spin do
      state = receiver.initial_state(*args)
      loop do
        msg = receive
        reply, state = receiver.send(msg[:method], state, *msg[:args])
        msg[:from] << reply unless reply == :noreply
      end
    end
    build_api(coprocess, receiver)
    snooze
    coprocess
  end

  def self.build_api(coprocess, receiver)
    receiver.methods(false).each do |m|
      if m =~ /!$/
        coprocess.define_singleton_method(m) do |*args|
          GenServer.cast(coprocess, m, *args)
        end
      else
        coprocess.define_singleton_method(m) do |*args|
          GenServer.call(coprocess, m, *args)
        end
      end
    end
  end

  def self.cast(process, method, *args)
    process << {
      from:   Polyphony::Coprocess.current,
      method: method,
      args:   args
    }
  end

  def self.call(process, method, *args)
    process << {
      from:   Polyphony::Coprocess.current,
      method: method,
      args:   args
    }
    receive
  end
end

module Map
  def self.initial_state(hash = {})
    hash
  end

  def self.get(state, key)
    [state[key], state]
  end

  def self.put!(state, key, value)
    state[key] = value
    [:noreply, state]
  end
end

map_server = GenServer.start(Map, foo: :bar)

puts 'getting value from map server'
v = map_server.get(:foo)
puts "value: #{v.inspect}"

puts 'putting value in map server'
map_server.put!(:foo, 42)

puts 'getting value from map server'
v = map_server.get(:foo)
puts "value: #{v.inspect}"

map_server.stop

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
polyphony-0.23	examples/core/genserver.rb