面试题：Ruby响应式编程中的事件处理

Question

在Ruby的响应式编程中，如何使用`Observable`和`Observer`模式来处理事件？请编写一段代码示例，展示如何创建一个可观察对象，并订阅它以处理特定事件。

Answer 1

require 'rx'

# 创建一个可观察对象
observable = Rx::Observable.from([1, 2, 3, 4, 5])

# 订阅可观察对象以处理事件
observable.subscribe(
  on_next: lambda { |value| puts "接收到值: #{value}" },
  on_error: lambda { |error| puts "发生错误: #{error}" },
  on_complete: lambda { puts "序列完成" }
)