RxJS Marble Testing Setup for Ava

Helpers for using marble testing. with Ava testing framework

Note: This project was derived from rxjs-marble-testing for Jasmine/Wallaby.

Marble testing resources:

Status

It works :)

Currently depends on:

rxjs: ^5.0.0
ava: ^0.18.0

Getting Started

npm install rxjs-ava-marble-testing --save-dev

From your Terminal run:

ava --init

Follow steps in using Ava guide

Marble Test API

cold(marbles, values?, error?)
hot(marbles, values?, error?)
expectObservable(actualObservable)
expectSubscriptions(actualSubscriptions)
ajax with MockWebSocket and MockXMLHttpRequest

Example usage

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/from';
import 'rxjs/add/operator/filter';
import 'rxjs/add/operator/merge';

import { test } from 'ava'
import { marbles } from 'rxjs-ava-marble-testing'

test('The filter operator', t => {
    // to cleanup TestScheduler after each test run
    const m = marbles(t)

    m.it('should correctly filter non-even numbers', () => {
        const source = Observable.from<number>([1, 2, 3, 4, 5])
        const example = source.filter(num => num % 2 === 0)
        const values = { a: 2, b: 4 }
        const expected = '(ab|)'

        m.expectObservable(example).toBe(expected, values)
    })
});

//Example with expectSubscription
test('The merge operator', t => {
    const m = marbles(t)

    m.it('should merge two observables', () => {
        const values = { a: 1, b: 2, c: 3, d: 4 };
        const a = m.cold(' a-----b-----c----|', values)
        const asub = ('^-----------------!')
        const b = m.cold('---------d----------|', values)
        const bsub = '^-------------------!'
        const expected = '-a-----b-d---c------|'

        m.expectObservable(a.merge(b)).toBe(expected, values)
        m.expectSubscriptions(a.subscriptions).toBe(asub)
        m.expectSubscriptions(b.subscriptions).toBe(bsub)
    })
})

Ajax Mock helpers

MockWebSocket
MockXMLHttpRequest

Usage:

import { ajax } from 'rxjs-ava-marble-testing'

MockWebSocket class API

constructor(public url: string, public protocol: string)

Instance:

send(data: any): void
get lastMessageSent(): any
triggerClose(e: any): void
triggerError(err: any): void
triggerMessage(data: any): void
open(): void
close(code: any, reason: any): void
addEventListener(name: string, handler: any): void
removeEventListener(name: string, handler: any): void
trigger(name: string, e: any)

Static:

get lastSocket(): MockWebSocket
clearSockets(): void

MockXMLHttpRequest class API

constructor()