bellbind

## async-array.js


const Notifier = class {
  constructor() {
    this.waits = new Set();
  }
  get wait() {
    let d = {};
    const p = new Promise((f, r) => {
      d.r = r; d.f = f;

## cuckoo-filter.js
import {sha1} from "./sha1.js";

const te = new TextEncoder();
const eq = (a, b) => a && b && a.length === b.length &&
      a.every((v, i) => v === b[i]);

// cuckoo filter: https://en.wikipedia.org/wiki/Cuckoo_filter
export const CuckooFilter = class {
  constructor({
    fingerprintSize = 4, tableSize = 17, pushLimit = 128, hash = sha1

## web-streams-examples.js
// Web Streams API basic example for highWaterMark option

// 1. raw ReadableStream pattern
const rawReader = async () => {
  const blob = new Blob(["Hello ", "World"]);
  const rstream = blob.stream();

  const reader = rstream.getReader();
  try {
    for (let {value, done} = await reader.read(); !done;

## collator-ja.js
const col = new Intl.Collator("ja-JP");

console.log("[category]");
// Category order: symbol < number < kana < kanji < Greek < Cyrillic
console.log(col.compare("-", "←")); //=> -1 (A < B)
console.log(col.compare("←", "♪")); //=> -1 (A < B)
console.log(col.compare("♪", "0")); //=> -1 (A < B)
console.log(col.compare("9", "A")); //=> -1 (A < B)
console.log(col.compare("Z", "あ")); //=> -1 (A < B)
console.log(col.compare("ん", "亜")); //=> -1 (A < B)

## index.html
<!doctype html>
<html>
  <head>
    <script type="module">
const worker = new SharedWorker("./worker.js");
worker.port.addEventListener("message", ev => {
  document.body.textContent = `connected: ${ev.data}`;
});
worker.port.start(); // spawm connect event to a shared worker
    </script>

## index.html
<!doctype html>
<html>
  <head>
    <script type="module">
// https://dom.spec.whatwg.org/#interface-AbortController
const ac = new AbortController();
document.querySelector("#aborted").textContent = ac.signal.aborted;
ac.signal.addEventListener("abort", ev => {
  console.log("aborted"); // onabort spawned only once
  document.querySelector("#aborted").textContent = ac.signal.aborted;

## index-40.html
<!doctype html>
<html>
  <head>
    <title>Pubsub on libp2p (js-ipfs-0.40)</title>
    <script type="module" src="./main-40.js"></script>
  </head>
  <body>
    <h3 id="myid"></h3>
    <div>
      id: <input id="id" type="text" size="40"/>

## index-40.html
<!doctype html>
<html>
  <head>
    <title>Chat on libp2p (js-ipfs-0.40)</title>
    <script type="module" src="./main-40.js"></script>
  </head>
  <body>
    <h3 id="myid"></h3>
    <div>
      to: <input id="to" type="text" size="40"/>

## index.html
<!doctype html>
<html>
  <head>
    <script type="module">
// WICG Shape Detection API
// - https://wicg.github.io/shape-detection-api/
try {
  const start = document.getElementById("start");
  const video = document.getElementById("video");
  const result = document.getElementById("result");

## bitstream.js
// big endian bit stream
export class BitWriter {
  constructor(buf = [], byte = 0, pos = 7) {
    this.byte = byte;
    this.pos = pos;
    this.buf = Array.from(buf);
  }
  writeBit(b) {
    this.byte |= (b & 1) << this.pos;
    this.pos--;


	const Notifier = class {
	constructor() {
	this.waits = new Set();
	}
	get wait() {
	let d = {};
	const p = new Promise((f, r) => {
	d.r = r; d.f = f;
	import {sha1} from "./sha1.js";

	const te = new TextEncoder();
	const eq = (a, b) => a && b && a.length === b.length &&
	a.every((v, i) => v === b[i]);

	// cuckoo filter: https://en.wikipedia.org/wiki/Cuckoo_filter
	export const CuckooFilter = class {
	constructor({
	fingerprintSize = 4, tableSize = 17, pushLimit = 128, hash = sha1
	// Web Streams API basic example for highWaterMark option

	// 1. raw ReadableStream pattern
	const rawReader = async () => {
	const blob = new Blob(["Hello ", "World"]);
	const rstream = blob.stream();

	const reader = rstream.getReader();
	try {
	for (let {value, done} = await reader.read(); !done;
	const col = new Intl.Collator("ja-JP");

	console.log("[category]");
	// Category order: symbol < number < kana < kanji < Greek < Cyrillic
	console.log(col.compare("-", "←")); //=> -1 (A < B)
	console.log(col.compare("←", "♪")); //=> -1 (A < B)
	console.log(col.compare("♪", "0")); //=> -1 (A < B)
	console.log(col.compare("9", "A")); //=> -1 (A < B)
	console.log(col.compare("Z", "あ")); //=> -1 (A < B)
	console.log(col.compare("ん", "亜")); //=> -1 (A < B)
	<!doctype html>
	<html>
	<head>
	<script type="module">
	const worker = new SharedWorker("./worker.js");
	worker.port.addEventListener("message", ev => {
	document.body.textContent = `connected: ${ev.data}`;
	});
	worker.port.start(); // spawm connect event to a shared worker
	</script>
	// big endian bit stream
	export class BitWriter {
	constructor(buf = [], byte = 0, pos = 7) {
	this.byte = byte;
	this.pos = pos;
	this.buf = Array.from(buf);
	}
	writeBit(b) {
	this.byte \|= (b & 1) << this.pos;
	this.pos--;