Convenient wrapper for Godot ECMAScript to support Rxjs flows

godot-rxjs.js

import { fromEventPattern } from 'rxjs';

module.exports = {
  fromEvent(instance, target, signal) {
    return fromEventPattern(
      handler => {
        target.connect(signal, instance, handler);  
      },
      handler => {
        target.disconnect(signal, instance, handler);  
      }
    );
  }
}

rx-example.jsx

import { fromEvent } from 'godot-rxjs';
import { merge } from 'rxjs/operators';

export default class InventoryUI extends godot.Control {
  _ready() {
    merge(
      fromEvent(InventorySingleton, this, 'add_item'),
      fromEvent(InventorySingleton, this, 'remove_item'),
    ).subscribe(() => this.refreshUI());
  }
  
  refreshUI() {
    const itemList = this.get_node("ItemList");
    
    itemList.clear();
    for (let item of Inventory.items) {
      const {
        name,
        amount,
      } = item;
      itemList.add_item(`${name}: x${amount}`);
      const idx = itemList.get_item_count();
      itemList.set_item_metadata(idx, item);
    }
  }
}