Piping, buffering, filtering, mapping, and general hypothetical combinations API.

01-buffer-flow.ts

import { buffer, on, flow, filter } from "effection";
  
let results = flow(
  on('message'),
  buffer({ size: 100 }),
  map(message => JSON.parse(message.data)),
  filter(data => data.type === "result"),
);
  
let websocket = new WebSocket('wss://localhost:9000');
  
// in this example, forEach is not a combinator, just a regular function
yield* forEach(results(websocket), function*(result) {
  console.log('received result from websocket', result)
});

02-buffer-pipe.ts

import { buffer, on, pipe, filter } from "effection";
  
yield* pipe(
  new WebSocket('wss://localhost:9000'),
  on('message'),
  buffer({ size: 100 }),
  map(message => JSON.parse(message.data)),
  filter(data => data.type === "result"),
  forEach(function*() {
    console.log('received result from websocket', result)  
  })
);

03-buffer-foreach-pipe.ts

import { buffer, on, flow, filter } from "effection";
  
let results = flow(
  on('message'),
  buffer({ size: 100 }),
  map(message => JSON.parse(message.data)),
  filter(data => data.type === "result"),
);
  
let websocket = new WebSocket('wss://localhost:9000');
  
yield* pipe(websocket, results, forEach(function*(result) {
  console.log('received result from websocket', result)
}));

04-for-each-simple.ts

import { on, pipe } from "effection";
    
let websocket = new WebSocket('wss://localhost:9000');
  
yield* pipe(websocket, on("message"), forEach(function*(message) {
  console.log('received message from websocket', message)
}));