import { Message, MessageType } from "silentium";

/**
 * By receiving a message with a key and value, collects a table
 * of all previously received messages in the form of a structure
 * https://silentium-lab.github.io/silentium-components/#/structures/hash-table
 */
export function HashTable<T>($base: MessageType<[string, unknown]>) {
  return Message<T>(function HashTableImpl(r) {
    const record: Record<string, unknown> = {};
    $base.then(function hashTableBaseSub([key, value]) {
      record[key] = value;
      r({ ...record } as T);
    });
  });
}