Callbag basics 👜

기본적인 callbag 팩토리와 오퍼레이터들을 제공하는 라이브러리입니다.

callbag-basics 은 callbag 이라는 명세를 따르는 함수들을 구현한 라이브러리에요.

Callbag 은 말이죠..:

스트림을 통한 리액티브 프로그래밍을 지원해요.
Iterable 을 이용한 프로그래밍을 지원해요. (얘는 덤이에요!)
모든 오퍼레이터가 위 두가지 사항을 지원해요.
작아요! 라이브러리의 크기는 고작 7kB 에요.
빨라요! xstream 과 RxJS 보다 빨라요.
확장 가능성: 코어 라이브러리가 없어요! 모든 게 유틸리티 함수에요!

Observable 과 (비동기)Iterable이 합쳐지는 걸 상상해보세요. 그게 바로 callbag 이에요. 아, 그리고 하나 더!, callbag 의 내부는 정말 작을 수 밖에 없어요. 왜냐하면 모든 걸 몇 개의 간단한 콜백으로 해내기 때문이죠! 결과적으로 callbag 명세를 따라 프로그래밍을 하는 것은 작고 빠른 프로그램을 만드는 데 도움이 되요.

사용법

npm install callbag-basics

팩토리와 오퍼레이터는 다음과 같이 불러와요:

const {forEach, fromIter, map, filter, pipe} = require('callbag-basics');

온라인에서 사용해보기

리액티브 프로그래밍 예제

<button> 엘리먼트의 클릭 이벤트에서 XY 좌표를 로깅하기:

Log XY coordinates of click events on <button> elements:

const {forEach, fromEvent, map, filter, pipe} = require('callbag-basics');

pipe(
  fromEvent(document, 'click'),
  filter(ev => ev.target.tagName === 'BUTTON'),
  map(ev => ({x: ev.clientX, y: ev.clientY})),
  forEach(coords => console.log(coords))
);

// {x: 110, y: 581}
// {x: 295, y: 1128}
// ...

매 초마다 하나의 자연수를 연산하여, 총 5개의 가장 작은 홀수를 얻기:

const {forEach, interval, map, filter, take, pipe} = require('callbag-basics');

pipe(
  interval(1000),
  map(x => x + 1),
  filter(x => x % 2),
  take(5),
  forEach(x => console.log(x))
);

// 1
// 3
// 5
// 7
// 9

Iterable 프로그래밍 예제

숫자들의 열에서, 5개의 숫자를 뽑고, 뽑은 숫자들을 4로 나눈 후 하나씩 출력하기:

const {forEach, fromIter, take, map, pipe} = require('callbag-basics');

function* range(from, to) {
  let i = from;
  while (i <= to) {
    yield i;
    i++;
  }
}

pipe(
  fromIter(range(40, 99)), // 40, 41, 42, 43, 44, 45, 46, ...
  take(5), // 40, 41, 42, 43, 44
  map(x => x / 4), // 10, 10.25, 10.5, 10.75, 11
  forEach(x => console.log(x))
);

// 10
// 10.25
// 10.5
// 10.75
// 11

API

아래의 리스트에 있는 함수들을 callbag-basics가 제공하고 있어요.

Source 팩토리

Sink 팩토리

forEach

변환 오퍼레이터

필터 오퍼레이터

병합 오퍼레이터

유틸리티

share
pipe

그리고 더!

위키를 확인해보세요!

용어사전

source: 데이터를 발송하는 callbag
sink: 데이터를 수신하는 callbag
puller sink: source 에게 데이터를 발송하기를 요구하는 sink
pullable source: 데이터를 발송하기를 요구받아야지만 데이터를 발송하는 source
listener sink: 수동적으로 source 로부터 데이터를 수신하는 sink
listenable source: 자발적으로 sink 로 데이터를 발송하는 source
operator: 다른 callbag 에 특정 연산을 적용하는 callbag

Contributing

The Callbag philosophy is: build it yourself. :) You can send pull requests, but even better, don't depend on the repo owner accepting it. Just fork the project, customize it as you wish, and publish your fork on npm. As long as it follows the callbag spec, everything will be interoperable! :)

ENvironmentSet/readme.md