@cosmjs/stream
Advanced tools
Comparing version 0.30.1 to 0.31.0-alpha.1
@@ -6,2 +6,5 @@ "use strict"; | ||
class DefaultValueProducer { | ||
get value() { | ||
return this.internalValue; | ||
} | ||
constructor(value, callbacks) { | ||
@@ -11,5 +14,2 @@ this.callbacks = callbacks; | ||
} | ||
get value() { | ||
return this.internalValue; | ||
} | ||
/** | ||
@@ -16,0 +16,0 @@ * Update the current value. |
@@ -6,3 +6,3 @@ import { Stream } from "xstream"; | ||
*/ | ||
export declare type SameTypeStreamOperator<T> = (ins: Stream<T>) => Stream<T>; | ||
export type SameTypeStreamOperator<T> = (ins: Stream<T>) => Stream<T>; | ||
/** | ||
@@ -9,0 +9,0 @@ * Drops duplicate values in a stream. |
import { Stream } from "xstream"; | ||
export declare type ReducerFunc<T, U> = (acc: U, evt: T) => U; | ||
export type ReducerFunc<T, U> = (acc: U, evt: T) => U; | ||
export declare class Reducer<T, U> { | ||
@@ -4,0 +4,0 @@ private readonly stream; |
import { MemoryStream } from "xstream"; | ||
import { DefaultValueProducer } from "./defaultvalueproducer"; | ||
export declare type SearchFunction<T> = (value: T) => boolean; | ||
export type SearchFunction<T> = (value: T) => boolean; | ||
/** | ||
@@ -5,0 +5,0 @@ * A read only wrapper around DefaultValueProducer that allows |
@@ -11,2 +11,5 @@ "use strict"; | ||
class ValueAndUpdates { | ||
get value() { | ||
return this.producer.value; | ||
} | ||
constructor(producer) { | ||
@@ -16,5 +19,2 @@ this.producer = producer; | ||
} | ||
get value() { | ||
return this.producer.value; | ||
} | ||
/** | ||
@@ -21,0 +21,0 @@ * Resolves as soon as search value is found. |
{ | ||
"name": "@cosmjs/stream", | ||
"version": "0.30.1", | ||
"version": "0.31.0-alpha.1", | ||
"description": "Utility functions for producing and consuming streams", | ||
@@ -54,3 +54,3 @@ "contributors": [ | ||
"@types/karma-jasmine-html-reporter": "^1", | ||
"@types/node": "^15.0.1", | ||
"@types/node": "^18", | ||
"@typescript-eslint/eslint-plugin": "^5.54.0", | ||
@@ -78,7 +78,8 @@ "@typescript-eslint/parser": "^5.54.0", | ||
"ts-node": "^8", | ||
"typedoc": "^0.22", | ||
"typescript": "~4.6", | ||
"typedoc": "^0.23", | ||
"typescript": "~4.9", | ||
"webpack": "^5.76.0", | ||
"webpack-cli": "^4.6.0" | ||
} | ||
}, | ||
"stableVersion": "0.30.1" | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
30426