Merge pull request #3 from Asterless/doc

Add method description comments consistent with `core` and perform partial translation

Author: CGaaaaaa

src/examples.mbt

@@ -1,38 +1,37 @@
 /// ReactiveX for MoonBit - 使用示例
 /// 展示基本的Observable创建和订阅功能
 
+///|
 /// 基础使用示例
 pub fn example_basic_usage() -> Unit {
   println("=== 基础使用示例 ===")
-  
+
   // 1. 创建一个简单的Observable
   let simple_obs = of(42)
   let _ = simple_obs.subscribe_next(fn(value) {
     println("接收到值: {value}")
   })
-  
+
   // 2. 创建数组Observable
   let array_obs = from_array([1, 2, 3])
   let _ = array_obs.subscribe_next(fn(value) {
     println("数组元素: {value}")
   })
-  
   println("=== 示例完成 ===")
 }
 
+///|
 /// 操作符链示例
 pub fn example_operator_chain() -> Unit {
   println("=== 操作符链示例 ===")
-  
+
   // 简单的操作符链
   let processed = from_array([1, 2, 3, 4, 5])
-    |> filter(fn(x) { x % 2 == 1 })  // 只保留奇数
-    |> map(fn(x) { x * x })          // 平方
-    |> take(3)                       // 取前3个
-  
+    |> filter(fn(x) { x % 2 == 1 }) // 只保留奇数
+    |> map(fn(x) { x * x }) // 平方
+    |> take(3) // 取前3个
   let _ = processed.subscribe_next(fn(value) {
     println("处理后的值: {value}")
   })
-  
   println("=== 示例完成 ===")
-}
+}

src/pkg.generated.mbti

@@ -0,0 +1,96 @@
+// Generated using `moon info`, DON'T EDIT IT
+package "CGaaaaaa/reactivex/src"
+
+// Values
+fn[T] catch_error(Observable[T], (RxError) -> Observable[T]) -> Observable[T]
+
+fn[T, U, V] combine_latest(Observable[T], Observable[U], (T, U) -> V) -> Observable[V]
+
+fn[T] concat(Array[Observable[T]]) -> Observable[T]
+
+fn[T] debounce(Observable[T], Int) -> Observable[T]
+
+fn[T : Eq] distinct(Observable[T]) -> Observable[T]
+
+fn[T] empty() -> Observable[T]
+
+fn[T] error(String) -> Observable[T]
+
+fn[T] error_with_type(RxError) -> Observable[T]
+
+fn example_basic_usage() -> Unit
+
+fn example_operator_chain() -> Unit
+
+fn[T] filter(Observable[T], (T) -> Bool) -> Observable[T]
+
+fn[T, U] flat_map(Observable[T], (T) -> Observable[U]) -> Observable[U]
+
+fn[T] from_array(Array[T]) -> Observable[T]
+
+fn[T, U] map(Observable[T], (T) -> U) -> Observable[U]
+
+fn[T] merge(Array[Observable[T]]) -> Observable[T]
+
+fn[T] never() -> Observable[T]
+
+fn[T] new_observable((Observer[T]) -> BasicSubscription) -> Observable[T]
+
+fn[T] new_observer((T) -> Unit, (RxError) -> Unit, () -> Unit) -> Observer[T]
+
+fn[T] new_simple_observer((T) -> Unit, (String) -> Unit, () -> Unit) -> Observer[T]
+
+fn new_subscription() -> BasicSubscription
+
+fn[T] of(T) -> Observable[T]
+
+fn[T, U] reduce(Observable[T], U, (U, T) -> U) -> Observable[U]
+
+fn[T] retry(Observable[T], Int) -> Observable[T]
+
+fn[T, U] scan(Observable[T], U, (U, T) -> U) -> Observable[U]
+
+fn[T] skip(Observable[T], Int) -> Observable[T]
+
+fn[T] start_with(Observable[T], T) -> Observable[T]
+
+fn[T, U] switch_map(Observable[T], (T) -> Observable[U]) -> Observable[U]
+
+fn[T] take(Observable[T], Int) -> Observable[T]
+
+fn[T] tap(Observable[T], (T) -> Unit) -> Observable[T]
+
+fn[T, U, V] zip(Observable[T], Observable[U], (T, U) -> V) -> Observable[V]
+
+// Errors
+
+// Types and methods
+pub struct BasicSubscription {
+  mut subscribed : Bool
+}
+fn BasicSubscription::is_subscribed(Self) -> Bool
+fn BasicSubscription::unsubscribe(Self) -> Unit
+
+pub struct Observable[T] {
+  subscribe_fn : (Observer[T]) -> BasicSubscription
+}
+fn[T] Observable::subscribe(Self[T], Observer[T]) -> BasicSubscription
+fn[T] Observable::subscribe_next(Self[T], (T) -> Unit) -> BasicSubscription
+
+pub struct Observer[T] {
+  on_next : (T) -> Unit
+  on_error : (RxError) -> Unit
+  on_complete : () -> Unit
+}
+
+pub enum RxError {
+  RuntimeError(String)
+  OperatorError(String)
+  SubscriptionError(String)
+  TimeoutError(String)
+}
+
+// Type aliases
+
+// Traits
+