medios

Meidos

Your lovely and versatile maids

install

$ yarn add medios

Usage

import {Task} from 'medios'
 
const Task = new Queue(2)
let count = 0
 
Task.push(async next => {
  expect(++count).toBe(1)
  await next()
  expect(++count).toBe(4)
})
 
Task.push(next => {
  expect(++count).toBe(2)
  next()
})
 
Task.push( async next => {
  await next()
  expect(++count).toBe(5)
})
 
Task.push( next => {
  expect(++count).toBe(3)
})

import {Message} from 'medios'
 
const message = new Message()
let count = 1
 
message.on('set', (value) => {
  count = value
})
message.emit('set', 1000)
expect(count).toBe(1000)
 

import  {Observer} from 'medios'
 
const observer = new Observer()
 
observer.subscribe(val => {
  expect(++val).toBe(2) 
})
 
observer.subscribe(val => {
  expect(--val).toBe(0)
})
 
observer.publish(1)