(string | Array<A | string>) => MapperFunctionType<B, PredicateFunctionType<A | string>> => MapperFunctionType<unknown, C> => MapperFunctionType<Array<A | string>, MapperFunctionType<number, D>> => StreamType => any
Takes a marble string, an assertion, a final state callback, and a stream so that you can assert in tests how a stream will function. Each marble should be deliniated by a "---" notation. If the last marble node is a "|" then it will make sure the stream has ended. Each "marble" will be evaluated before being compared.
test("String diagram", ({equal, doesNotThrow, end}) => {
const left = xstream.of("a")
const right = xstream.of("b")
streamSatisfies(
"'b'---'a'---|"
)(
(given) => (expected) => equal(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("String diagram", ({equal, doesNotThrow, end}) => {
const left = xstream.of(1)
const right = xstream.of(2)
streamSatisfies(
"2---1---|"
)(
(given) => (expected) => equal(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("String diagram", ({same, equal, doesNotThrow, end}) => {
const left = xstream.of({aaa: "aaa"})
const right = xstream.of({bbb: "bbb"})
streamSatisfies(
"{bbb: \"bbb\"}---{aaa: \"aaa\"}---|"
)(
(given) => (expected) => same(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("String diagram", ({equal, doesNotThrow, end}) => {
const left = xstream.of("a")
const right = xstream.of("b")
streamSatisfies(
"'b'---'a'--=>"
)(
(given) => (expected) => equal(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("Array diagram", ({equal, doesNotThrow, end}) => {
const left = xstream.of("a")
const right = xstream.of("b")
streamSatisfies(
["b", "a"]
)(
(given) => (expected) => equal(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("Array diagram", ({equal, doesNotThrow, end}) => {
const left = xstream.of(1)
const right = xstream.of(2)
streamSatisfies(
[2, 1]
)(
(given) => (expected) => equal(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("Array diagram", ({same, equal, doesNotThrow, end}) => {
const left = xstream.of({aaa: "aaa"})
const right = xstream.of({bbb: "bbb"})
streamSatisfies(
[{bbb: "bbb"}, {aaa: "aaa"}]
)(
(given) => (expected) => same(given, expected)
)(
doesNotThrow
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
mergeRight(left)(right)
)
})
test("Array diagram with error", ({equal, match, end}) => {
const stream = xstream
.from([
{unction: () => true},
{unction: () => true},
null,
])
.map((object) => object.unction())
streamSatisfies(
[true, true]
)(
(given) => (expected) => equal(given, expected)
)(
(exception) => {
match(exception, TypeError)
end()
}
)(
({length}) => (size) => {
equal(length, size)
end()
}
)(
stream
)
})