Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(pipe): add piped operators #75

Merged
merged 112 commits into from
Oct 29, 2017
Merged
Changes from 1 commit
Commits
Show all changes
112 commits
Select commit Hold shift + click to select a range
94cad27
feat(pipe): add piped operators
mattpodwysocki Oct 10, 2017
bfec28e
Merge branch 'master' of https://github.com/ReactiveX/IxJS into pipe
mattpodwysocki Oct 17, 2017
336f46f
feat(pipe): add through concat
mattpodwysocki Oct 17, 2017
cbb309d
feat(pipe): merge from master
mattpodwysocki Oct 17, 2017
468d246
Merge branch 'master' of https://github.com/ReactiveX/IxJS into pipe
mattpodwysocki Oct 23, 2017
007faea
Merge branch 'master' of https://github.com/ReactiveX/IxJS into pipe
mattpodwysocki Oct 23, 2017
a7e7ad7
feat(pipe): add through defaultIfEmpty
mattpodwysocki Oct 23, 2017
152fc06
feat(pipe): add through delay
mattpodwysocki Oct 23, 2017
8b071ad
feat(pipe): add through delayEach
mattpodwysocki Oct 23, 2017
4a6b817
feat(pipe): add through distinct
mattpodwysocki Oct 23, 2017
29f7eb8
feat(pipe): add through distinctUntilChanged
mattpodwysocki Oct 23, 2017
c19313d
feat(pipe): add through doWhile
mattpodwysocki Oct 23, 2017
25c6f21
feat(pipe): add through endwith
mattpodwysocki Oct 23, 2017
9d099e1
feat(pipe): add through except
mattpodwysocki Oct 23, 2017
883b776
feat(pipe): add through expand
mattpodwysocki Oct 23, 2017
45fddaf
feat(pipe): add through filter
mattpodwysocki Oct 23, 2017
2fcd230
feat(pipe): add through finally
mattpodwysocki Oct 24, 2017
60fde4b
feat(pipe): add through flatmap
mattpodwysocki Oct 24, 2017
9c43e9d
feat(pipe): add through flatten
mattpodwysocki Oct 24, 2017
dcac250
feat(pipe): add through groupby
mattpodwysocki Oct 24, 2017
3503a6d
feat(pipe): add through groupjoin
mattpodwysocki Oct 24, 2017
613c50e
feat(pipe): add through ignoreelements
mattpodwysocki Oct 24, 2017
94892c7
feat(pipe): add through innerjoin
mattpodwysocki Oct 24, 2017
caf1bcb
feat(pipe): add through intersect
mattpodwysocki Oct 24, 2017
fad4faa
feat(pipe): add through map
mattpodwysocki Oct 24, 2017
c9fc03b
feat(pipe): add through memoize
mattpodwysocki Oct 24, 2017
4fcbb0f
feat(pipe): add through merge
mattpodwysocki Oct 24, 2017
7fdf0b8
feat(pipe): add through mergeAll
mattpodwysocki Oct 24, 2017
3e55e4f
feat(pipe): add through minby
mattpodwysocki Oct 24, 2017
3de02e0
feat(pipe): add through onerrorresumenext
mattpodwysocki Oct 24, 2017
7b2bf03
feat(pipe): add through pairwise
mattpodwysocki Oct 24, 2017
7cb72c5
feat(pipe): add through pluck
mattpodwysocki Oct 24, 2017
ae15b1c
Merge branch 'master' of https://github.com/ReactiveX/IxJS into pipe
mattpodwysocki Oct 24, 2017
753c1cb
feat(pipe): add through publish
mattpodwysocki Oct 24, 2017
bddb837
feat(pipe): add through repeat
mattpodwysocki Oct 24, 2017
baf7996
Merge branch 'master' of https://github.com/ReactiveX/IxJS into pipe
mattpodwysocki Oct 24, 2017
c908085
feat(pipe): add through retry
mattpodwysocki Oct 24, 2017
da5f342
feat(pipe): add through reverse
mattpodwysocki Oct 24, 2017
8f321e1
feat(pipe): add through scan
mattpodwysocki Oct 24, 2017
6e1f577
feat(pipe): add through scanRight
mattpodwysocki Oct 24, 2017
b52a2d1
feat(pipe): add through share
mattpodwysocki Oct 24, 2017
b1f1365
feat(pipe): add through skip
mattpodwysocki Oct 24, 2017
fb566f3
feat(pipe): add through skipLast
mattpodwysocki Oct 24, 2017
b8e0844
feat(pipe): add through skipUntil
mattpodwysocki Oct 24, 2017
efefa91
feat(pipe): add through skipWhile
mattpodwysocki Oct 24, 2017
338f5e4
feat(pipe): add through slice
mattpodwysocki Oct 24, 2017
0d8a61a
feat(pipe): add through startwith
mattpodwysocki Oct 24, 2017
60dabc8
feat(pipe): add through take
mattpodwysocki Oct 24, 2017
6ded104
feat(pipe): add through takelast
mattpodwysocki Oct 24, 2017
30644d5
feat(pipe): add through takeuntil
mattpodwysocki Oct 24, 2017
977efa2
feat(pipe): add through takewhile
mattpodwysocki Oct 24, 2017
010b959
feat(pipe): add through tap
mattpodwysocki Oct 24, 2017
f44726d
feat(pipe): add through throttle
mattpodwysocki Oct 24, 2017
829e89e
feat(pipe): add through timeinterval
mattpodwysocki Oct 24, 2017
bae08b4
feat(pipe): add through timeout
mattpodwysocki Oct 24, 2017
b42c22e
feat(pipe): add through timestamp
mattpodwysocki Oct 24, 2017
236819d
feat(pipe): add through union
mattpodwysocki Oct 24, 2017
0f497af
feat(pipe): add through buffer
mattpodwysocki Oct 25, 2017
f1b9e48
feat(pipe): add through catch
mattpodwysocki Oct 25, 2017
d03709f
feat(pipe): add through catchWith
mattpodwysocki Oct 25, 2017
9096bbc
feat(pipe): add through concat
mattpodwysocki Oct 25, 2017
01eab69
feat(pipe): add through concatall
mattpodwysocki Oct 25, 2017
3aa1000
feat(pipe): add through defaultifempty
mattpodwysocki Oct 25, 2017
4575fb7
feat(pipe): add through distinct
mattpodwysocki Oct 25, 2017
8aee912
feat(pipe): add through distinctuntilchanged
mattpodwysocki Oct 25, 2017
b1ee24c
feat(pipe): add through dowhile
mattpodwysocki Oct 25, 2017
35d84e9
feat(pipe): add through endwith
mattpodwysocki Oct 25, 2017
b1cf9e5
feat(pipe): add through except
mattpodwysocki Oct 25, 2017
e63cf1a
feat(pipe): add through expand
mattpodwysocki Oct 25, 2017
da38818
feat(pipe): add through filter
mattpodwysocki Oct 25, 2017
80f029f
feat(pipe): add through finally
mattpodwysocki Oct 25, 2017
ecf76d8
feat(pipe): add through flatmap
mattpodwysocki Oct 25, 2017
1c90a65
feat(pipe): add through flatten
mattpodwysocki Oct 25, 2017
d534118
feat(pipe): add through groupjoin
mattpodwysocki Oct 25, 2017
70fc256
feat(pipe): add through ignorelements
mattpodwysocki Oct 25, 2017
c8989cd
feat(pipe): add through innerjoin
mattpodwysocki Oct 25, 2017
438b5c4
feat(pipe): add through intersect
mattpodwysocki Oct 25, 2017
000fbfe
feat(pipe): add through map
mattpodwysocki Oct 25, 2017
53ce45a
feat(pipe): add through maxby
mattpodwysocki Oct 25, 2017
16be746
feat(pipe): add through memoie
mattpodwysocki Oct 25, 2017
f628703
feat(pipe): add through minby
mattpodwysocki Oct 25, 2017
b1c39ac
feat(pipe): add through onerrorresumenext
mattpodwysocki Oct 25, 2017
b46c7f2
feat(pipe): add through pairwise
mattpodwysocki Oct 25, 2017
ab8ece6
feat(pipe): add through pluck
mattpodwysocki Oct 25, 2017
75f971e
feat(pipe): add through publish
mattpodwysocki Oct 25, 2017
054ae84
feat(pipe): add through repeat
mattpodwysocki Oct 25, 2017
b4c2b7a
feat(pipe): add through retry
mattpodwysocki Oct 25, 2017
b9a0b3c
feat(pipe): add through reverse
mattpodwysocki Oct 25, 2017
b4bfe6d
feat(pipe): add through scan
mattpodwysocki Oct 25, 2017
15a8eb3
feat(pipe): add through scanright
mattpodwysocki Oct 25, 2017
8164e88
feat(pipe): add through share
mattpodwysocki Oct 25, 2017
1b1e116
feat(pipe): add through skip
mattpodwysocki Oct 25, 2017
d148ba3
feat(pipe): add through skiplast
mattpodwysocki Oct 25, 2017
610c39f
feat(pipe): add through skipwhile
mattpodwysocki Oct 25, 2017
24e87ae
feat(pipe): add through slice
mattpodwysocki Oct 25, 2017
2e76d23
feat(pipe): add through startwith
mattpodwysocki Oct 25, 2017
7c5667c
feat(pipe): add through take
mattpodwysocki Oct 25, 2017
298bcc5
feat(pipe): add through takelast
mattpodwysocki Oct 25, 2017
d1c99b5
feat(pipe): add through takewhile
mattpodwysocki Oct 25, 2017
d9fe714
feat(pipe): add through tap
mattpodwysocki Oct 25, 2017
37e15af
feat(pipe): add through union
mattpodwysocki Oct 25, 2017
3cb4080
feat(pipe): add through pipe
mattpodwysocki Oct 25, 2017
df6b7b9
feat(pipe): moving pipe and forEach to core
mattpodwysocki Oct 25, 2017
fec0e36
feat(pipe): adds of and from to base
mattpodwysocki Oct 26, 2017
88e0591
feat(pipe): fix build
mattpodwysocki Oct 26, 2017
aa84905
style(lint): update code lint friendly (#116)
kwonoj Oct 27, 2017
35773d7
feat(from): make from on non-iterables coerce to iterables (#117)
trxcllnt Oct 27, 2017
e05ec24
feat(pipe): add to __modules
mattpodwysocki Oct 28, 2017
2e147a7
feat(pipe): add to __modules
mattpodwysocki Oct 28, 2017
4ecff97
feat(pipe): adding piped tests
mattpodwysocki Oct 28, 2017
7cc833c
fix pipe exports (#119)
trxcllnt Oct 29, 2017
8e62fe4
test(helpers): disable missing pipe fn logging
trxcllnt Oct 29, 2017
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
feat(pipe): add through timeout
  • Loading branch information
mattpodwysocki committed Oct 24, 2017
commit bae08b415ebcd12d9ebbcdf42204c8957aa90b99
9 changes: 9 additions & 0 deletions src/asynciterable/pipe/timeout.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
import { MonoTypeOperatorAsyncFunction } from '../../interfaces';
import { AsyncIterableX } from '../../asynciterable';
import { TimeoutAsyncIterable } from '../timeout';

export function timeout<TSource>(dueTime: number): MonoTypeOperatorAsyncFunction<TSource> {
return function timeoutOperatorFunction(source: AsyncIterable<TSource>): AsyncIterableX<TSource> {
return new TimeoutAsyncIterable<TSource>(source, dueTime);
};
}
2 changes: 1 addition & 1 deletion src/asynciterable/timeout.ts
Original file line number Diff line number Diff line change
@@ -17,7 +17,7 @@ interface TimeoutOperation<T> {
value?: IteratorResult<T>;
}

class TimeoutAsyncIterable<TSource> extends AsyncIterableX<TSource> {
export class TimeoutAsyncIterable<TSource> extends AsyncIterableX<TSource> {
private _source: AsyncIterable<TSource>;
private _dueTime: number;