Matthew Podwysocki mattpodwysocki

Open Sourcerer and Software Engineer at MapBox working on the Location AI Team

mattpodwysocki / bindcallback.ts

Last active October 18, 2017 04:07

	import { AsyncIterableX } from '../asynciterable';
	import { AsyncSink } from '../asyncsink';
	import { memoize } from './memoize';

	export function bindCallback<TSource>(
	func: Function,
	selector: Function
	): (...args: any[]) => AsyncIterableX<TSource> {
	return function(...args: any[]) {

mattpodwysocki / concat.ts

Created October 17, 2017 02:35

	import { AsyncIterableX } from '../asynciterable';

	class ConcatAsyncIterable<TSource> extends AsyncIterableX<TSource> {
	private _source: Iterable<AsyncIterable<TSource>>;

	constructor(source: Iterable<AsyncIterable<TSource>>) {
	super();
	this._source = source;
	}

mattpodwysocki / server.js

Created October 16, 2017 17:42

	const http = require('http')
	const port = 3000

	const requestHandler = (request, response) => {
	console.log(request.url)
	response.end('Hello Node.js Server!')
	}

	const server = http.createServer(requestHandler)

mattpodwysocki / pipe.ts

Created October 10, 2017 04:17

	import { OperatorAsyncFunction } from '../interfaces';
	import { AsyncIterableX } from '../asynciterable';

	/* tslint:disable:max-line-length */
	export function pipe<T>(source: AsyncIterable<T>): AsyncIterableX<T>;
	export function pipe<T, A>(source: AsyncIterable<T>, op1: OperatorAsyncFunction<T, A>): AsyncIterableX<A>;
	export function pipe<T, A, B>(source: AsyncIterable<T>, op1: OperatorAsyncFunction<T, A>, op2: OperatorAsyncFunction<A, B>): AsyncIterableX<B>;
	export function pipe<T, A, B, C>(source: AsyncIterable<T>, op1: OperatorAsyncFunction<T, A>, op2: OperatorAsyncFunction<A, B>, op3: OperatorAsyncFunction<B, C>): AsyncIterableX<C>;
	export function pipe<T, A, B, C, D>(source: AsyncIterable<T>, op1: OperatorAsyncFunction<T, A>, op2: OperatorAsyncFunction<A, B>, op3: OperatorAsyncFunction<B, C>, op4: OperatorAsyncFunction<C, D>): AsyncIterableX<D>;
	export function pipe<T, A, B, C, D, E>(source: AsyncIterable<T>, op1: OperatorAsyncFunction<T, A>, op2: OperatorAsyncFunction<A, B>, op3: OperatorAsyncFunction<

mattpodwysocki / buffer-pipe.ts

Last active October 10, 2017 03:18

	import { OperatorAsyncFunction } from '../../interfaces';
	import { AsyncIterableX } from '../../asynciterable';
	import { BufferAsyncIterable } from '../buffer';

	export function buffer<TSource>(
	count: number,
	skip?: number): OperatorAsyncFunction<TSource, TSource[]> {
	if (skip == null) { skip = count; }
	return function bufferCountOperatorFunction(source: AsyncIterable<TSource>): AsyncIterableX<TSource[]> {
	return new BufferAsyncIterable<TSource>(source, count, skip!);

mattpodwysocki / merge.ts

Last active October 5, 2017 05:39

	import { AsyncIterableX } from '../asynciterable';

	// tslint:disable-next-line:no-empty
	const NEVER_PROMISE = new Promise(() => { });

	class MergeAsyncIterable<T> extends AsyncIterableX<T> {
	private _source: AsyncIterable<T>[];

	constructor(source: AsyncIterable<T>[]) {
	super();

mattpodwysocki / stream.js

Created October 5, 2017 02:09

	'use strict';

	import * as fs from 'fs';
	import { AsyncSink, AsyncIterable } from 'ix';
	AsyncIterable.from(fs
	.createReadStream('some.file')
	.pipe(new AsyncSink()))
	.flatMap(file => /* yes */)
	.forEach(/* HEAVEN */)

mattpodwysocki / append.ts

Created September 25, 2017 18:15

	'use strict';

	import { AsyncIterableX } from '../asynciterable';
	import { MonoTypeAsyncIteratorOperatorFunction } from '../interfaces';

	export class AppendAsyncIterable<TSource> extends AsyncIterableX<TSource> {
	private _source: AsyncIterable<TSource>;
	private _args: TSource[];

	constructor(source: AsyncIterable<TSource>, args: TSource[]) {

mattpodwysocki / merge.ts

Created September 18, 2017 16:49

	'use strict';

	import { AsyncIterableX } from '../asynciterable';

	function neverPromiseFactory<T>() {
	// tslint:disable-next-line:no-empty
	return new Promise<T>(() => { });
	}

	class MergeAsyncIterable<T> extends AsyncIterableX<T> {

mattpodwysocki / cask-upgrade.sh

Created September 7, 2017 19:04