fudini

var toObservable = request => Rx.Observable.create(observer => {
  var req = request.end((err, res) => {
    if(err) {
      observer.onError(err)
    } else {
      observer.onNext(res)
      observer.onComplete()
    }
  })
  return Rx.Disposable.create(() => {

fudini

const combineObject = config => {

  const streams = _.values(config)
  const keys = _.keys(config)

  return Rx.Observable.combineLatest(
    ...streams,
    (...values) => _.zip(values, keys).reduce((acc, [value, key]) => {
      acc[key] = value
      return acc

fudini

const pageSize = 10

const getPage = page => {

    const pageContent = _.range(0, pageSize).map(v => v + (page * pageSize))
      
    if(page == 9) {

        return Rx.Observable.just({
            nextPage: null,

fudini

use std::mem;
use std::slice;

pub struct Pool {
    uncommited: usize,
    ptr: *mut u8
}

impl Pool {