antirez
|
f3b3ca41f7
|
Streams: fix XREAD timeout handling, zero is valid.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
6d54ec5e24
|
Streams: XREAD ability to block fixed.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
b6f1106630
|
Streams: synchronous xread fixes and improvements.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
6f79b52dfa
|
Streams: XREAD, first draft. Handling of blocked clients still missing.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
54e221af43
|
Streams: XREAD arguments parsing.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
428bb7cca0
|
Streams: augment client.bpop with XREAD specific fields.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
a168cbef13
|
Streams: implement stream object release.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
760ad8f65c
|
Streams: XLEN command.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
f028e4e68e
|
Streams: RDB saving.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
e4e216f8cc
|
Streams: assign value of 6 to OBJ_STREAM + some refactoring.
|
2017-12-01 10:24:24 +01:00 |
|
antirez
|
71ad8ff26e
|
Streams: 12 commits squashed into the initial Streams implementation.
|
2017-12-01 10:24:24 +01:00 |
|